| Both sides previous revisionPrevious revision | |
| kafka [2026/05/19 14:27] – reddy | kafka [2026/05/19 14:29] (current) – reddy |
|---|
| <code> | <code> |
| # List topics | # List topics |
| ./bin/kafka-topics.sh --bootstrap-server=ip-172-31-29-161.me-central-1.compute.internal:9092,ip-172-31-17-47.me-central-1.compute.internal:9092,ip-172-31-22-213.me-central-1.compute.internal:9092 --list | ./bin/kafka-topics.sh --bootstrap-server=a.xyz:9092,b.xyz:9092,c.xyz:9092 --list |
| |
| # Create a topic for testing | # Create a topic for testing |
| ./bin/kafka-topics.sh --bootstrap-server=ip-172-31-29-161.me-central-1.compute.internal:9092,ip-172-31-17-47.me-central-1.compute.internal:9092,ip-172-31-22-213.me-central-1.compute.internal:9092 --create --topic topic1 --partitions 1 --replication-factor 3 --config retention.ms=-1 --config retention.bytes=524288000 --config max.message.bytes=30000000 --config flush.messages=1 | ./bin/kafka-topics.sh --bootstrap-server=a.xyz:9092,b.xyz:9092,c.xyz:9092 --create --topic topic1 --partitions 1 --replication-factor 3 --config retention.ms=-1 --config retention.bytes=524288000 --config max.message.bytes=30000000 --config flush.messages=1 |
| |
| # List topics | # List topics |
| ./bin/kafka-topics.sh --bootstrap-server=ip-172-31-29-161.me-central-1.compute.internal:9092,ip-172-31-17-47.me-central-1.compute.internal:9092,ip-172-31-22-213.me-central-1.compute.internal:9092 --list | ./bin/kafka-topics.sh --bootstrap-server=a.xyz:9092,b.xyz:9092,c.xyz:9092 --list |
| |
| # See details for the topic | # See details for the topic |
| ./bin/kafka-topics.sh --bootstrap-server=ip-172-31-29-161.me-central-1.compute.internal:9092,ip-172-31-17-47.me-central-1.compute.internal:9092,ip-172-31-22-213.me-central-1.compute.internal:9092 --describe --topic topic1 | ./bin/kafka-topics.sh --bootstrap-server=a.xyz:9092,b.xyz:9092,c.xyz:9092 --describe --topic topic1 |
| |
| # To change the replication factor for a topic, use the "kafka-reassign-partitions" utility | # To change the replication factor for a topic, use the "kafka-reassign-partitions" utility |
| ]} | ]} |
| EOF | EOF |
| kafka-reassign-partitions --bootstrap-server=ip-172-31-29-161.me-central-1.compute.internal:9092,ip-172-31-17-47.me-central-1.compute.internal:9092,ip-172-31-22-213.me-central-1.compute.internal:9092 --reassignment-json-file partcfg.json --execute | kafka-reassign-partitions --bootstrap-server=a.xyz:9092,b.xyz:9092,c.xyz:9092 --reassignment-json-file partcfg.json --execute |
| |
| # To change any other config for an existing topic | # To change any other config for an existing topic |
