禁用卡夫卡的生产商从性质的结构

0

的问题

怎么可以生产者设立的从卡夫卡的工厂被禁用?

我开始从这个例子 https://docs.spring.io/spring-kafka/reference/html/ enter image description here

我预计,增加一个酒店似的

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

将禁止的消息发送,但它似乎没有工作。 运行的应用程序仍将发送消息。

1

最好的答案

3

有没有生产者财产像 autoStartup,因此,这并不意味着 disable the message sending. 对于生产者的配置,你可以看到 在这里.

在弹簧卡夫卡, autoStartup 用于 监听的容器.

你可以设置这种财产: 在 @KafkaListener

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

**ListenerContainerFactory.setAutoStartup(Boolean autoStartup)

2021-11-22 11:40:09

因此,没有解决我的问题吗? 我想要禁止的是卡夫卡的生产者使用的性质。
Scala

可以@KafkaListener可用于生产者还?
Scala

是的,有没有酒店的意义 disable the kafka producer. @KafkaListener 只是用于消费者(ListenerContainer). 一KafkaTemplate发送你的消息上的需求,所以,如果你想停止,只是不要叫它。
Linh Vu

其他语言

此页面有其他语言版本

Русский
..................................................................................................................
Italiano
..................................................................................................................
Polski
..................................................................................................................
Română
..................................................................................................................
한국어
..................................................................................................................
हिन्दी
..................................................................................................................
Français
..................................................................................................................
Türk
..................................................................................................................
Česk
..................................................................................................................
Português
..................................................................................................................
ไทย
..................................................................................................................
Español
..................................................................................................................
Slovenský
..................................................................................................................