Kafka消费者（应该）如何应对有毒信息
当Kafka消费者未能反序列化消息时，客户端应用程序是否有责任处理Poison Message？
或者
Kafka 是否“递增”了消息偏移并继续使用有效消息？
是否有处理Kafka主题中的有害信息的“最佳实践”？
共有1个答案
当Kafka无法反序列化记录时，消费者将收到＜code＞org.apache.Kafka.common。KafkaException，您应该自己提交偏移量并继续使用。
-
我想描述以下场景：我有一个节点。js后端应用程序（它使用单线程事件循环）。这是系统的总体架构：Producer- 假设制作者向Kafka发送了一条消息，这条消息的目的是在数据库中进行某个查询并检索查询结果。但是，众所周知Kafka是一个异步系统。如果制作者向Kafka发送消息，它会得到一个响应，表明该消息已被Kafka经纪人接受。Kafka broker不会等到消费者轮询消息并处理它。 在这种情况
-
有什么方法可以阻止Kafka的消费者在一段时间内消费信息吗？我希望消费者停止一段时间，然后开始消费最后一条未消费的消息。
-
我有一个简单的Kafka消费者微服务应用程序，它使用来自某个主题的消息，同一个应用程序运行在两个不同的池中。 所以，当消息由制作人生成，而我的应用程序尝试使用来自主题的消息时，它只被一个池中的一个人使用。 如何停止从消费者Kafka读取并发消息。我想在两个池中使用相同的消息。 这种情况下可能的解决方案是什么
-
本文向大家介绍Kafka 的消费者如何消费数据相关面试题，主要包含被问及Kafka 的消费者如何消费数据时的应答技巧和注意事项，需要的朋友参考一下 消费者每次消费数据的时候，消费者都会记录消费的物理偏移量（offset）的位置 等到下次消费时，他会接着上次位置继续消费
-
由于它是一个Spring Boot应用程序，默认偏移量设置为Latest。我在这里做错了什么，请帮我弄明白。
-
我刚接触Kafka，很少阅读教程。我无法理解使用者和分区之间的关系。 请回答我下面的问题。 > 消费者是否由ZK分配到单个分区，如果是，如果生产者将消息发送到不同的分区，那么其他分区的消费者将如何使用该消息？ 我有一个主题，它有3个分区。我发布消息，它会转到P0。我有5个消费者（不同的消费者群体）。所有消费者都会阅读P0的信息吗？若我增加了许多消费者，他们会从相同的P0中阅读信息吗？如果所有消费者