消费者收到后删除Kafka短信
提前谢谢你。
共有1个答案
-
我们有一个制作人 在开发过程中，我重新部署了producer应用程序，并做了一些更改。但在此之后，我的消费者没有收到任何消息。我尝试重新启动消费者，但没有成功。问题可能是什么和/或如何解决？ 消费者配置： 生产者配置： 编辑2： 5分钟后，消费者应用程序死亡，但以下情况除外：
-
我正在使用以下在docker上运行kafka、zookeeper和kafdrop： 我有一个具有以下配置的Spring Boot Producer应用程序-: 在我的中，我有以下内容： 这是一个单独的应用程序,我在我的服务中这样称呼Kafka制作人： 在一个完全不同的spring引导应用程序中，我有一个像这样的使用者: 我可以看到消费者正在连接到代理，但是有消息的日志。下面是我能看到的完整日志：
-
是否有一种方法以编程方式访问和打印使用者滞后偏移，或者说使用者读取的最后一条记录的偏移与某个生产者写入该使用者分区的最后一条记录的偏移之间的位置差。 要知道我的最终目标是将这个值发送到prometheus进行监视，我应该在上面添加哪些语句来得到滞后偏移值？
-
我是Kafka的新手。我在网上读了很多关于Kafka制作人和Kafka消费者的说明。我成功地实现了前者，它可以向Kafka集群发送消息。然而，我没有完成后一个。请帮我解决这个问题。我看到我的问题像StackOverflow上的一些帖子，但我想更清楚地描述一下。我在虚拟盒子的Ubuntu服务器上运行Kafka和Zookeeper。使用1个Kafka集群和1个Zookeeper集群的最简单配置（几乎是
-
我在Kafka做数据复制。但是，kafka日志文件的大小增长很快。一天内大小达到5 gb。作为这个问题解决方案，我想立即删除处理过的数据。我正在使用AdminClient中的delete record方法删除偏移量。但当我查看日志文件时,对应于该偏移量的数据不会被删除。 我不想要类似（log.retention.hours,log.retention.bytes,log.segment.bytes
-
在某些情况下，我使用Kafka流对主题的小内存（hashmap）投影进行建模。K，V缓存确实需要一些操作，因此它不是GlobalKTable的好例子。在这种“缓存”场景中，我希望我的所有兄弟实例都具有相同的缓存，因此我需要绕过消费者组机制。 要实现这一点，我通常只需使用随机生成的应用程序ID启动我的应用程序，因此每个应用程序每次重新启动都会重新加载主题。唯一的警告是，我最终会有一些消费者群体在Ka