我们如何使用API从IDE在Kafka中创建主题,因为当我这样做时:
bin/kafka-create-topic.sh --topic mytopic --replica 3 --zookeeper localhost:2181
我收到错误:
bash: bin/kafka-create-topic.sh: No such file or directory
我按照原样关注了开发人员设置.
我正在使用 kafka_2.10-0.10.0.1。我创建了 1 个分区的主题。我知道默认的清理策略是“删除”。我想一直保留主题中的所有记录（不删除任何记录）。什么是正确的方法：使“log.cleaner.enable=false”或“log.cleanup.policy=compact”？谢谢你
我们正在使用 Apache Kafka，并且有很多手动创建的主题（使用自定义主题配置）。我们希望像代码一样管理我们的主题，就像我们的基础设施/配置的其余部分一样。
我们如何以编程方式和声明方式管理我们的主题？什么是理智的方法？