从属性配置中禁用 kafka 生产者
Disable kafka producer from properties configuration
如何禁用从 Kafka 工厂设置的生产者?
我从这个例子开始 https://docs.spring.io/spring-kafka/reference/html/
我希望添加一个 属性 喜欢
props.put("autoStartup", "false");
将禁用消息发送,但它似乎不起作用。
运行 应用程序仍在发送消息。
没有像autoStartup
这样的制作人属性,所以不代表disable the message sending
。对于生产者配置,您可以看到 here.
在Spring Kafka中,autoStartup
用于Listener Container。
您可以通过以下方式设置 属性:
在@KafkaListener
@KafkaListener(id = "myContainer", topics = "myTopic", autoStartup = "false")
或
**ListenerContainerFactory.setAutoStartup(Boolean autoStartup)
如何禁用从 Kafka 工厂设置的生产者?
我从这个例子开始 https://docs.spring.io/spring-kafka/reference/html/
我希望添加一个 属性 喜欢
props.put("autoStartup", "false");
将禁用消息发送,但它似乎不起作用。 运行 应用程序仍在发送消息。
没有像autoStartup
这样的制作人属性,所以不代表disable the message sending
。对于生产者配置,您可以看到 here.
在Spring Kafka中,autoStartup
用于Listener Container。
您可以通过以下方式设置 属性:
在@KafkaListener
@KafkaListener(id = "myContainer", topics = "myTopic", autoStartup = "false")
或
**ListenerContainerFactory.setAutoStartup(Boolean autoStartup)