这貌似还是使用了 kafkaconsumer函数 kafkaconsumer函数在不存在topic时 会创建对应的topic 我看官网文档并没有看见相关的配置 可以不创建topic
时间: 2024-05-20 18:14:30 浏览: 105
KafkaMiddleWare:利用kafka开发的一个中间件,其可以根据配置创建topic,向指定的topic中发送消息以及消费消息。其可打包供生产端和消费端调用
你说的没错,`kafkaconsumer`函数在不存在topic时会创建对应的topic。如果你不想让`kafkaconsumer`函数自动创建topic,可以通过以下方式进行配置:
1. 在kafka的配置文件(`server.properties`)中,将`auto.create.topics.enable`设置为`false`,这样kafka就不会自动创建不存在的topic了。
2. 如果你使用的是KafkaConsumer API,可以在创建KafkaConsumer实例时,将`auto.offset.reset`设置为`none`,这样当KafkaConsumer订阅不存在的topic时,就会抛出异常而不是自动创建topic。
但是需要注意的是,如果你不想让`kafkaconsumer`函数自动创建topic,并且确保你的程序不会因为订阅不存在的topic而出现异常,那么建议在程序中先手动创建所有需要使用的topic。
阅读全文