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
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
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