从属性配置中禁用 kafka 生产者答案

【问题标题】：Disable kafka producer from properties configuration从属性配置中禁用 kafka 生产者
【发布时间】：2021-12-31 20:15:30
【问题描述】：

如何禁用从 Kafka 工厂设置的生产者？

我希望添加类似的属性

props.put("autoStartup", "false");

将禁用消息发送，但它似乎不起作用。运行应用程序仍会发送消息。

【问题讨论】：

【解决方案1】：

没有像autoStartup 这样的生产者属性，所以它并不意味着disable the message sending。对于生产者配置，您可以看到here。

在 Spring Kafka 中，autoStartup 用于Listener Container。

您可以通过以下方式设置此属性：在@KafkaListener

@KafkaListener(id = "myContainer", topics = "myTopic", autoStartup = "false")

或者

**ListenerContainerFactory.setAutoStartup(Boolean autoStartup)

【讨论】：

所以我的问题没有解决方案？我想使用属性禁用 kafka 生产者。
@KafkaListener 也可以用于生产者吗？
是的，没有属性意味着disable the kafka producer。 @KafkaListener 仅用于消费者 (ListenerContainer)。 KafkaTemplate 按需发送您的消息，因此如果您想停止，请不要调用它。