Kafka：删除主题如何运作

Question

bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic T.AB_KAFF

bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server localhost:9092 --describe --group G.AB_KAFF

主题的最后状态：

组,主题,分区,当前偏移量,日志结束偏移量,滞后,所有者G.AB_KAFF,T.AB_KAFF,0,5,5,0,Consumer-2_/127.0.0.1 G.AB_KAFF,T.AB_KAFF,1,5,5,0,Consumer-2_/127.0.0.1

现在我删除主题。并将邮件发布到此主题

那么为什么Kafka要把滞后设定为-ve数。这难道不是一个潜在的问题吗？

假设我再次订阅已删除的主题，所以在其-ve滞后为0之前，我将不会收到任何消息

其他信息:
-我正在本地运行3个kafka节点
-我添加了属性：delete.topic.enable=true
-创建此主题时使用分区=2，复制-factor=2

Answer 1

一旦你删除一个主题，它的记录存储在Kafaka将丢失。因此，对最新偏移量的查询返回0。

组中的使用者实例定期提交特定主题__consumer-offset-{0..49}中的上次读取记录偏移量。在延迟计算期间，它执行latestoffset-lastreadrecordoffset，因此在主题删除后，kafka-consumers-groups命令中显示负延迟。

[kamal@tcltest1 bin]$ sh kafka-run-class.sh kafka.tools.GetOffsetShell --topic test --time -1 --broker-list localhost:9092 # Query to get latest offset
test:0:1000
[kamal@tcltest1 bin]$ sh kafka-topics.sh --topic test --zookeeper localhost:2181 --delete
Topic test is marked for deletion.
Note: This will have no impact if delete.topic.enable is not set to true.
[kamal@tcltest1 bin]$ sh kafka-run-class.sh kafka.tools.GetOffsetShell --topic test --time -1 --broker-list localhost:9092 # After deletion
[kamal@tcltest1 bin]$ 

存储在Zookeeper中的元数据将被异步删除。（如果我错了请纠正我）

[kamal@tcltest1 bin]$ sh zookeeper-shell.sh localhost:2181
Connecting to localhost:2181
Welcome to ZooKeeper!
JLine support is disabled

WATCHER::

WatchedEvent state:SyncConnected type:None path:null
get /brokers/topics/test/partitions/0/state
{"controller_epoch":1,"leader":0,"version":1,"leader_epoch":0,"isr":[0]}
cZxid = 0x13c
ctime = Thu Jun 09 09:56:05 IST 2016
mZxid = 0x13c
mtime = Thu Jun 09 09:56:05 IST 2016
pZxid = 0x13c
cversion = 0
dataVersion = 0
aclVersion = 0
ephemeralOwner = 0x0
dataLength = 72
numChildren = 0