我们有一个在openshift中运行的两节点kafka tcluster。我们创建了一个保留策略设置为30天的主题。这项工作与预期一样,包括单个代理重新启动。但是,当kafka集群通过将kafka statefulset缩减为0个副本并将其缩减为2个副本来重新启动时,所有主题消息都将消失。
重新启动群集之前:
/usr/bin/kafka运行类kafka.tools.getoffsetshell—代理列表localhost:29092 --topic platforms.openshift.events--时间-1--偏移量1
平台.openshift。events:0:73387
群集重新启动后:
$/usr/bin/kafka运行类kafka.tools.getoffsetshell--代理列表localhost:29092 --topic platforms.openshift.events--时间-1--偏移量1
平台.openshift。events:0:0
是预期行为吗?我们使用装入的卷存储Kafka主题。
1条答案
按热度按时间lvjbypge1#
我注意到的是kafka.properteis set log.dirs=/var/lib/kafka/data not/var/lib/kafka。将卷装入点从/var/lib/kafka更改为/var/lib/kafka/data之后,问题就消失了。