2017-02-24 84 views
0

测试期间我会执行一些操作,如删除主题。 不过我可以以后immeidately删除它卡夫卡操作中的延迟

使用请参阅主题:斌/ kafka-topics.sh --list --zookeeper本地主机:2181 这需要一些时间,以实际发生的缺失。

这使我困惑。

同样,当我产生的数据,我不能立即消费,但必须等待一段时间,并重新运行消费命令消费数据。

是因为我正在运行单个节点kafka设置并且我正在对它进行过度测试。

回答

0
  1. 如果你想删除一个主题,你需要通过经纪人设置delete.topic.enable启用它。

  2. 删除主题“异步”发生,也就是说,在您发出删除命令后,主题被标记为“将被删除”,代理将在稍后的某个时间点删除该主题。

  3. 关于生产/消费:不确定。如果消费者在线并且生产者写入数据,它应该在消费者后不久...

+0

谢谢你这么多马蒂亚斯。 –

+0

1.因此我启用了delete.topic.enable。 2.所以我明白,该主题仍然可以看到,不会立即删除。 3.我在调用“bin/kafka-producer-perf-test.sh”后立即调用“bin/kafka-consumer-perf-test.sh”,并将acks设置为-1。 –

+0

任何我可以通过同步生产者消息的方式将是有用的..最好使用“bin/kafka-producer-perf-test.sh” –