From b493677b3467214ebf02b726bf24f16540b4c1f5 Mon Sep 17 00:00:00 2001 From: kev Date: Fri, 27 Jul 2018 14:46:38 +0800 Subject: [PATCH] update kafka --- kafka/README.md | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/kafka/README.md b/kafka/README.md index 98339d8..ef19282 100644 --- a/kafka/README.md +++ b/kafka/README.md @@ -14,11 +14,13 @@ kafka $ docker-compose up -d $ docker-compose exec kafka bash >>> kafka-topics.sh --create --zookeeper zookeeper:2181 --replication-factor 1 --partitions 2 --topic my-topic +>>> kafka-topics.sh --alert --zookeeper zookeeper:2181 --topic my-topic --config retention.hours=168 +>>> kafka-topics.sh --alert --zookeeper zookeeper:2181 --topic my-topic --delete-config retention.hours >>> exit # Producer $ kafkacat -P -b localhost:9092 -t my-topic # Consumer -$ kafkacat -C -b localhost:9092 -t my-topic -o end +$ kafkacat -C -b localhost:9092 -t my-topic -o end -u -q | jq . ```