Hi Marcus,
What Ran meant is that please run the following command to check the
result.
bin/kafka-topics.sh --describe --topic TOPIC_NAME --bootstrap-server
localhost:9092
Thanks.
Luke
On Thu, Jul 1, 2021 at 8:06 PM Ran Lupovich <ranlupov...@gmail.com> wrote:
> I meant kafka-topics describe command , I want to make sure your topic
> really have 20 partitions
>
> בתאריך יום ה׳, 1 ביולי 2021, 14:12, מאת Marcus Schäfer <
> marcus.schae...@gmail.com>:
>
> > Hi,
> >
> > > How many partitions do you have for the topic? Can you issue --describe
> > > please and share, thanks
> >
> > I've assigned 20 partitions:
> >
> > aws kafka describe-configuration-revision --region eu-central-1 --arn
> > "..." --revision 1
> > base64 --decode ...
> >
> > auto.create.topics.enable=false
> > default.replication.factor=3
> > min.insync.replicas=2
> > num.io.threads=8
> > num.network.threads=5
> > num.partitions=20
> > num.replica.fetchers=2
> > replica.lag.time.max.ms=30000
> > socket.receive.buffer.bytes=102400
> > socket.request.max.bytes=104857600
> > socket.send.buffer.bytes=102400
> > unclean.leader.election.enable=true
> > zookeeper.session.timeout.ms=18000
> >
> >
> > aws kafka describe-cluster --region eu-central-1 --cluster-arn "..."
> >
> > {
> > "ClusterInfo": {
> > "BrokerNodeGroupInfo": {
> > "BrokerAZDistribution": "DEFAULT",
> > "ClientSubnets": [
> > "subnet-XX",
> > "subnet-XX"
> > ],
> > "InstanceType": "kafka.m5.large",
> > "SecurityGroups": [
> > "sg-XX"
> > ],
> > "StorageInfo": {
> > "EbsStorageInfo": {
> > "VolumeSize": 100
> > }
> > }
> > },
> > "ClusterArn": "...",
> > "ClusterName": "cb-cluster",
> > "CreationTime": "2021-06-24T07:00:15.158Z",
> > "CurrentBrokerSoftwareInfo": {
> > "ConfigurationArn": "...",
> > "ConfigurationRevision": 1,
> > "KafkaVersion": "2.6.1"
> > },
> > "CurrentVersion": "K3T4TT2Z381HKD",
> > "EncryptionInfo": {
> > "EncryptionAtRest": {
> > "DataVolumeKMSKeyId": "..."
> > },
> > "EncryptionInTransit": {
> > "ClientBroker": "TLS_PLAINTEXT",
> > "InCluster": true
> > }
> > },
> > "EnhancedMonitoring": "DEFAULT",
> > "OpenMonitoring": {
> > "Prometheus": {
> > "JmxExporter": {
> > "EnabledInBroker": false
> > },
> > "NodeExporter": {
> > "EnabledInBroker": false
> > }
> > }
> > },
> > "NumberOfBrokerNodes": 2,
> > "State": "ACTIVE",
> > "Tags": {},
> > "ZookeeperConnectString": ""
> > }
> > }
> >
> > Thanks
> >
> > Regards,
> > Marcus
> > --
> > Public Key available via: https://keybase.io/marcus_schaefer/key.asc
> > keybase search marcus_schaefer
> > -------------------------------------------------------
> > Marcus Schäfer Am Unterösch 9
> > Tel: +49 7562 905437 D-88316 Isny / Rohrdorf
> > Germany
> > -------------------------------------------------------
> >
>
