我正在使用Kafka(与雅虎Kafka经理)我想为重设消息设置一个规则或者它们如何称之为“分区偏移量之和”在server.properties中是否有滚动kafka偏移的参数?(即:我要重置或删除所有影响邮件保留的参数)谢谢。
lvmkulzt1#
创建主题后,不能通过更改默认值来更改主题保留策略。删除保留是按主题的,如果在创建时未给定,则使用默认值。如果您想动态更改主题保留策略,可以使用下面的命令;
./kafka-topics.sh --zookeeper your_server_ip:2181 --alter --topic your_topic_name --config retention.ms=604800000
这需要几分钟才能生效。
1条答案
按热度按时间lvmkulzt1#
创建主题后,不能通过更改默认值来更改主题保留策略。删除保留是按主题的,如果在创建时未给定,则使用默认值。
如果您想动态更改主题保留策略,可以使用下面的命令;
这需要几分钟才能生效。