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
-------------------------------------------------------
signature.asc
Description: Digital signature
