如何暂停/启动/停止Kafka制作人/Kafka模板
我正在使用一个与kafka集成的spring boot应用程序，我想实现一个endpoint来停止和启动kafka发布消息。消息由另一个endpoint以异步方式触发。
豆子卡夫卡模板
我的目标是能够模拟连接失败，并确保这些消息存储在我已经准备好的后备机制中。
有什么想法吗？
共有1个答案
KafkaTemplate没有这些回调，因为它是一个被动组件，只有在我们调用它时才能执行这些操作。
对于连接失败的模拟，我建议您实现一个自定义的OUerWorks，生成一个带有模拟或覆盖未来的KafkaOUer
org.apache.kafka.clients.producer.MockOUer可能有一些东西可供您重用或借用。例如，请参阅其关闭（）或f的生产者（）。
-
我将为消息实现断路器模式。基本要求是，如果微服务无法将消息发布到发布主题，则应停止接受来自其他 Kafka 主题的消息。当发布主题可用时，微服务应开始接受来自其他 Kafka 主题的消息。 有没有一种方法可以在Spring BootKafka Streams中实现这一点？
-
由于本机KafkaConsumer不是线程安全的，因此不鼓励从不同的线程而不是kafka使用者处理线程调用pause和resume方法。但正如spring kafka提供的另一层kafka信息容器，内部使用kafka consumer。所以我的问题是，我们可以使用KafkaListenerEndpointRegistry通过id获取侦听器容器，并从其他线程而不是消费者处理线程调用resume或pa
-
1.若要暂停训练，请按下该按钮。显示暂停。若要继续训练，请点击绿色箭头图标。 2.若要停止训练，在记录训练期间或处于暂停模式时长按该按钮三秒钟，直至计数器清零。或者您可以点击并按住显示屏上的红色停止按钮。 如果在暂停后停止训练，则暂停后经过的时间不包括在总训练时间内。
-
若要暂停训练 长按正面按钮 或 在训练视图中向右滑动，找出并轻触暂停图标。 通过向左滑动您可以在暂停模式中看到训练总结。 恢复暂停的训练 轻触绿色箭头图标。 停止训练 在训练期间或在暂停模式中，长按正面按钮直至绿色计时器一直倒数。 或 在暂停模式中，轻触并按住红色停止图标可结束记录。
-
1.若要暂停训练，请按“返回”按钮。显示“记录已暂停”。若要继续训练，请按“开始”。 2.若要停止训练，在训练记录或处于暂停模式时长按“返回”按钮三秒钟，直到显示“记录已结束”。 如果在暂停后停止训练，则暂停后经过的时间不包括在总训练时间内。
-
我想暂停Kafka听众。 我叫http://localhost:8080/pause暂停容器 我发送有关主题的数据。 消费者开始消费消息 我原以为消费者会被暂停，但Kafka主题的信息仍在阅读中。如何暂停消费者？我用的是2.5。0（Spring启动父级）