在方法上使用@KafkaListener。我有什么方法来跟踪我的消费者在这方面走了多远
我使用SpringBoot，特别是SpringKafka库来使用kafka。
在使用消息的方法之一上，我有一个带有@KafkaListener注释的类。我能读懂这些信息。我意识到这是一个话题，而信息总是以制作人的身份出现。我想要某种暗示，我在最后一个偏移量，这样我就可以用另一个来源触发我的重新调解逻辑。我怎样才能抓住这个线索。有我可以订阅/收听的活动吗？
共有1个答案
您可以设置containeridleEventInterval属性，并且（每个使用者线程）将在该间隔期间未收到任何记录时发出一个ListenerContainerIdleEvent。
使用ApplicationListener或@EventListener方法使用事件。
-
问题内容： 为什么这个简单的Python代码不起作用？ 这是我得到的错误： 我已经在几个不同的页面上尝试过，但是我永远无法获得正确执行的方法。 问题答案： 您的代码不是这里的问题。 IE中是否有任何代理设置？ 这表示urllib.urlopen的python文档： 在Windows环境中，如果未设置代理环境变量，则将 从注册表的“ Internet设置” 部分获取代理设置。
-
我正在使用Brave库https://github.com/openzipkin/brave进行跟踪，现在我也想将其用于Kafka消费者。我想避免添加Spring Sleuth，并利用Brave Kafka仪器https://github.com/openzipkin/brave/tree/master/instrumentation/kafka-clients. 对于Kafka消费者，我使用@K
-
当我尝试编译这段代码时
-
问题内容： 为什么我们在Java中使用该方法？（请给出有关内存限制的答案。）这会减少内存使用吗？如果是，那怎么办？这样会减少内存泄漏的影响吗？ 问题答案： 除了 不使用克隆外，还实现一个复制构造函数 ，您询问了内存限制。 克隆 的想法是创建克隆对象的精确副本。因此，在最坏的情况下，此后您将使用两倍的内存量。实际上- 少了一点，因为String经常被嵌入并且（通常）不会被克隆。即使由clone方法/
-
本文向大家介绍为什么我们在jQuery中使用JSON.stringify()方法？，包括了为什么我们在jQuery中使用JSON.stringify()方法？的使用技巧和注意事项，需要的朋友参考一下 JSON或JavaScript Object Notation是一种轻量级的基于文本的开放标准，旨在用于人类可读的数据交换。使用JSON.stringify()方法将JavaScript对象转换为字符
-
问题内容： 这是我的方法： 我把它放回去。该方法有什么问题？ 问题答案： 您的条件应为i * i <= num 您未考虑数字9，因此9 <9将导致错误。但是您需要检查9。