Kafka遗失的信息
共有1个答案
我认为您没有指定使用者配置参数auto.offset.reset。默认值为last（对于pre v0.9，last)，但是您似乎希望将其设置为aresty(对于pre v0.9，smort)。
向KafKaconsumer添加is配置属性。
参见http://kafka.apache.org/0100/documentation.html#NewConsumerConfigs
-
下面的日志每次都在后面。（同一条消息的错误几乎是30倍） 我试着重新启动Kafka和Spring Boot应用程序，仍然是同样的问题。 日志： 听者 > 有什么解决方案可以停止收听错误消息吗？我使用了seekErrorHandler它有时只工作，有任何配置问题吗？ Kafka和Spring的Kafka有什么问题吗？ 如何解决这一问题？
-
我只是按照 https://devcenter.heroku.com/articles/newrelic#java-configuration 从步骤 将New Relic代理添加为Maven依赖项 直到步骤 将New Relic代理添加为Scala SBT/Play 2依赖项 要为我的Web服务（Jetty JAX-RS REST）安装New Relic插件。 我定制了这件新文物。yml（与po
-
你好，我正在使用Spring云流编写一个Kafka消费者生产者。在我的消费者内部，我将数据保存到数据库中，如果数据库出现故障，我将手动退出应用程序。重新启动应用程序后，如果数据库仍然关闭，则应用程序将再次停止。现在，如果我第三次重新启动应用程序，中间间隔（两次失败）收到的消息丢失，kafka 消费者会获取最新消息，也会跳过我退出代码的消息。 入站和出站通道绑定器接口 服务等级- 1)生产者服务 2
-
我们有kafka集群，包含3个kafka代理节点和3个zookeepers服务器 Kafka版本- 10.1 ( hortonworks) 根据我的理解，因为所有的元数据都位于zookeeper服务器上，kafka代理正在使用这些数据(kafka通过端口2181与zookeeper服务器对话) 我只是想知道是否每台kafka机器都与集群中的其他kafka交谈，或者kafka可能只在动物园管理员服务
-
什么是最好的方法来实现死信队列（DLQ）的概念在Spring Boot 2.0应用程序中使用sping-kafka 2.1. x有所有的消息被处理失败的@KafkaListener方法的一些bean发送到一些预定义的Kafka DLQ主题并且不丢失一条信息？ 因此，Kafka的记录是： 已成功处理， 处理失败，并发送到DLQ主题， 处理失败，未发送到DLQ主题（由于意外问题），因此将再次被侦听器使