Why does kafka-consumer-groups show the topics written to too in its describe

2017-08-06 Thread Sachin Mittal
Hi, I am executing following command bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server localhost:9092 --describe --group new-part-advice It gives output like GROUP TOPIC PARTITION CURRENT-OFFSET LOG-END-OFFSET LAG OWNER new-par

do i need to restart the brokers if I changed the retention time for a specific topic

2017-08-06 Thread haitao .yao
Hi, I want to change the retention time for a specific topic with the following command: $ bin/kafka-topics.sh --zookeeper zk_address --alter --topic test-topic --config retention.ms=8640 Is that correct? Do I have to restart the brokers? I read the source code and thought the configuration v

Re: do i need to restart the brokers if I changed the retention time for a specific topic

2017-08-06 Thread Kaufman Ng
Hi Haitao, The retention time (retention.ms) configuration can exist as a broker-level and/or topic-level config. For the latter, changing it does NOT require broker restarts. On Sun, Aug 6, 2017 at 10:33 PM, haitao .yao wrote: > Hi, I want to change the retention time for a specific topic wit