从属性配置中禁用 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)