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 > ------------------------------------------------------- >