如何关闭现有的kafka制作程序
我正在使用sping-kafka 2.2.7-RELEASE并编写生产者。我正在阅读从这里留档如下所述。
“从2.5版开始，每个版本都扩展了KafkaResourceFactory。这允许在运行时通过向它们的配置添加一个供应商来更改引导服务器：setBootstrapServersSupply ier(() → … ). 这将被调用以获取所有新连接的服务器列表。消费者和生产者通常是长期存在的。要关闭现有的生产者，请在DefaultKafkaProducerFactory上调用重置（）。要关闭现有的消费者，请在KafkaListenerEndpoint注册表和/或在任何其他侦听器容器bean上调用Stop（）和start（）"
https://docs.spring.io/spring-kafka/reference/html/#connecting
现在，我的问题是
- 何时以及如何调用此重置方法
- 如果我们使用的是像2.2.7这样的旧版本的spring-kafka，我们该如何处理
共有1个答案
>
每当您想连接到不同的代理时，只需在出厂时调用 reset（）。
旧版本不可能，必须创建新的工厂和模板。
-
我通过以下代码将阿帕奇 Avro 格式的消息发送到 Kafka 代理实例： 代码工作正常，消息最终在Kafka中并被处理以最终在ImphxDB中。问题是每次发送操作都会产生大量INFO消息（客户端ID号就是一个例子）： [生产者客户端 Id=生产者-27902] 关闭 Kafka 生产者超时Millis = 10000 毫秒。 [创建者客户端 Id=创建者-27902] 使用超时关闭 Kafka
-
我有一个多线程应用程序，它使用producer类生成消息，之前我使用下面的代码为每个请求创建producer。其中KafkaProducer是新建的，每个请求如下： 然后我阅读了关于生产者的Kafka文档，并了解到我们应该使用单个生产者实例来获得良好的性能。 然后我在一个singleton类中创建了KafkaProducer的单个实例。 现在什么时候 或者我们如何在关闭后重新连接到生产者。问题是如
-
我不想更改端口号，但收到异常“exception in thread”main“java.net.BindException:Address already in use：JVM_Bind” ServerSocket服务器=新服务器套接字（1234180）；
-
我正在处理xml，我需要每条记录发送一条消息，当我收到最后一条记录时，我关闭了kafka生产者，这里的问题是kafka生产者的发送方法是异步的，因此，有时当我关闭生产者时，它会拖曳我在某个地方读到过，我可以让制片人敞开心扉。我的问题是：这意味着什么，或者是否有更好的解决方案。 -编辑- 想象以下场景： 我们阅读标签并创建kafka生产者 对于每个元素，我们读取其属性，生成一个json对象并使用se
-
谁能告诉我如何在android中组合图像并生成一个mp4文件，并将视频文件存储在SDCard中？
-
问题内容： 在Swing中，您可以简单地用于在关闭窗口时关闭整个应用程序。 但是，在JavaFX中找不到等效项。我有多个打开的窗口，如果一个窗口关闭，我想关闭整个应用程序。用JavaFX做到这一点的方法是什么？ 编辑： 我了解可以覆盖以在窗口关闭时执行一些操作。问题是应该执行什么操作才能终止整个应用程序？ 类中定义的方法不执行任何操作。 问题答案： 当最后一个关闭时，应用程序自动停止。目前，您的类