|
|
|
|
@ -96,14 +96,14 @@ for i in {1..1000}; do echo "Hello $i times" | usr/bin/kafka-console-producer \
|
|
|
|
|
--broker-list localhost:19092, localhost:29092, localhost:39092 \ |
|
|
|
|
--topic MultiBrokerTopic; done |
|
|
|
|
|
|
|
|
|
$KAFKA_HOME/bin/kafka-console-producer.sh \ |
|
|
|
|
--broker-list localhost:9092 \ |
|
|
|
|
--topic my-topic \ |
|
|
|
|
--property "parse.key=true" \ |
|
|
|
|
--property "key.separator=:" |
|
|
|
|
key1:value1 |
|
|
|
|
key2:value2 |
|
|
|
|
key3:value3 |
|
|
|
|
# $KAFKA_HOME/bin/kafka-console-producer.sh \ |
|
|
|
|
# --broker-list localhost:9092 \ |
|
|
|
|
# --topic my-topic \ |
|
|
|
|
# --property "parse.key=true" \ |
|
|
|
|
# --property "key.separator=:" |
|
|
|
|
# key1:value1 |
|
|
|
|
# key2:value2 |
|
|
|
|
# key3:value3 |
|
|
|
|
|
|
|
|
|
usr/bin/kafka-topics \ |
|
|
|
|
--create \ |
|
|
|
|
@ -121,7 +121,13 @@ usr/bin/kafka-topics \
|
|
|
|
|
|
|
|
|
|
usr/bin/kafka-topics --list --zookeeper localhost:22181 |
|
|
|
|
usr/bin/kafka-console-producer --broker-list localhost:19092, localhost:29092, localhost:39092 --topic KeyedTopic |
|
|
|
|
usr/bin/kafka-console-consumer --bootstrap-server localhost:39092 --from-beginning --group consumer_group_01 --topic KeyedTopic |
|
|
|
|
|
|
|
|
|
usr/bin/kafka-console-consumer \ |
|
|
|
|
--bootstrap-server localhost:39092 \ |
|
|
|
|
--from-beginning \ |
|
|
|
|
--group consumer_group_02 \ |
|
|
|
|
--topic KeyedTopic |
|
|
|
|
|
|
|
|
|
usr/bin/kafka-consumer-groups --bootstrap-server localhost:39092 --list |
|
|
|
|
usr/bin/kafka-consumer-groups --bootstrap-server localhost:39092 --describe --group consumer_group_01 |
|
|
|
|
|
|
|
|
|
@ -132,8 +138,9 @@ usr/bin/kafka-console-consumer \
|
|
|
|
|
--topic KeyedTopic |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
\ |
|
|
|
|
for k in {a,b,c}; do \ |
|
|
|
|
for i in {1..5}; do \ |
|
|
|
|
for i in {1..100}; do \ |
|
|
|
|
echo "$k:Hello $i times using key $k" \ |
|
|
|
|
| usr/bin/kafka-console-producer \ |
|
|
|
|
--request-required-acks 1 \ |
|
|
|
|
@ -192,7 +199,7 @@ topic="MultiBrokerTopic"}
|
|
|
|
|
--entity-type topics \ |
|
|
|
|
--entity-name KeyedTopic \ |
|
|
|
|
--alter \ |
|
|
|
|
--add-config 'cleanup.policy=compact, delete.retention.ms=10000, segment.ms=100, segment.bytes=20000, min.cleanable.dirty.ratio=0.01, min.compaction.lag.ms=100, cleaner.min.compaction.lag.ms=100' |
|
|
|
|
--add-config 'cleanup.policy=compact, delete.retention.ms=10000, segment.ms=100, min.cleanable.dirty.ratio=0.01, min.compaction.lag.ms=100, min.compaction.lag.ms=100' |
|
|
|
|
|
|
|
|
|
/usr/bin/kafka-configs \ |
|
|
|
|
--zookeeper localhost:22181 \ |
|
|
|
|
|