《中邮消费金融》专题

我有一个 Kafka 应用程序，我一直在使用它 kafka-console-consumer.sh 使用消息，如下所示： 它提供了我通过Kafka消费者给Kafka经纪人写的所有消息，没有任何遗漏。 最近，我将该应用程序部署在另一个环境中，因为某些原因，zookeperhost无法访问。所以我使用的是kafka简单的消费者外壳。sh，如下所示： 但是有了这个，我看到很少的消息(大约5000个中有2

我的Kafka消费者的代码是这样的 我已经意识到，这种消费者设置无法读取所有信息。我无法再现这一点，因为这是一个间歇性的问题。 当我使用 将最后 100 条消息与此消费者进行比较时，我发现我的消费者间歇性地随机错过了几条消息。我的消费者有什么问题？ 在python中使用消息的方法太多了。应该有一种最好只有一种明显的方法来做到这一点。

本文向大家介绍那些情景下会造成消息漏消费？相关面试题，主要包含被问及那些情景下会造成消息漏消费？时的应答技巧和注意事项，需要的朋友参考一下 消费者没有处理完消息 提交offset(自动提交偏移 未处理情况下程序异常结束)

我想这个话题发生了什么...偏移坏了还是我不知道... 有人知道会发生什么吗？谢谢

我正在尝试设置一个基本的Java消费者来接收来自Kafka主题的消息。我在-https://cwiki.apache.org/confluence/display/KAFKA/Consumer组示例-并具有以下代码： 和 Kafka在有问题的EC2主机上运行，我可以使用kafka-console-producer.sh和kafka-console-consumer.sh工具发送和接收关于主题“测试

我正在使用spring kafka来消费来自kafka的消息。消费者监听器如下。 应用程序的单个实例，并发数为6。 该主题有6个分区。 从上面的日志中可以清楚地看到，两个用户在完全相同的时间收到了来自分区和偏移量的相同消息。 每个线程继续处理消息。最后，其中一个消费者失败了，错误如下 我知道上面的错误会在有负载或消息处理需要时间时出现。在这种情况下，处理不到一秒钟，kafka主题中的消息不到10条

我有1个消费者群体和5个消费者。也有5个分区，因此每个消费者得到1个分区。 CLI还显示 bin/Kafka-console-consumer . sh-bootstrap-server localhost:9092-Topic Topic-1-from-beginning-partition { n }正确显示每个分区的不同消息。 然而，我经常看到两个或两个以上的消费者在处理同一条信息，而且对于

本文向大家介绍什么是消费者或用户？相关面试题，主要包含被问及什么是消费者或用户？时的应答技巧和注意事项，需要的朋友参考一下 答：Kafka消费者订阅一个主题，并读取和处理来自该主题的消息。此外，有了消费者组的名字，消费者就给自己贴上了标签。换句话说，在每个订阅使用者组中，发布到主题的每个记录都传递到一个使用者实例。确保使用者实例可能位于单独的进程或单独的计算机上。 Apache Kafka对于新手

本文向大家介绍消费组与分区重平衡相关面试题，主要包含被问及消费组与分区重平衡时的应答技巧和注意事项，需要的朋友参考一下 当有新的消费者加入到消费者组时，原本的分区就需要重新分配；比如一个topic有30个分区，原本只有两个消费者，每人负责15个分区，当新加入一个消费者时，并没有分区可以给他消费，只能是将30个分区重新分配。 每个消费者组都会有一个broker负责协调（称为group coordin

我需要在我的应用程序中实现推送通知功能。探索一些选择。 谷歌最近推荐了Firebase平台，但这并不是完全免费的服务。所以我又想到了使用GCM。谷歌将来会停止对GCM的支持吗？

我在为 端口设置 消费者以捕获消息时遇到问题。我的： 申请开始： 并且＜code＞514＜/code＞端口已打开但未侦听 我可以在tcpdump中看到，tcpdump-I eth1-nn-A-s 0端口514和udp正确发送和接收消息。 有人能告诉我我做错了什么吗？

我正在尝试使用Akka和Camel的竞争性事件消费者实现。我使用Akka 2.3.2和Camel 5.8.0。我正在将camel连接到ActiveMQ代理，并使用生产者从另一端生成消息。在以下代码中，EventManager是创建消费者池的主机，Event处理器是消息处理演员。 EventManager.java EventProcessor.java 我看到的问题是，消息似乎被单个参与者使用，而

我正在尝试使用ReplyingKafkaTemplate，偶尔会看到下面的消息。 没有待处理的回复：消费者记录（主题=请求-回复-主题，分区=8，偏移量=1，创建时间=1544653843269，序列化密钥大小=-1，序列化值大小=1609，标题=记录标题（标题=[记录标题（键=kafka_correlationId，值=[-14,65,21，-118,70，-94,72,87，-113，-91,

我有两个Kafka监听器组件，每个组件监听不同的主题并期待不同的有效负载。我的问题是，我可以对两者使用相同的客户端id吗？还是必须使用不同的客户端id？如果客户端id必须不同，我想了解一个可以有效使用客户端id的用例。

我对kafka和kafka-python相当陌生。安装kafka-python后，我从这里尝试了一个简单的消费者代码实现-http://kafka-python.readthedocs.io/en/master/usage.html 我一直在kafka的bin目录中编写消费者代码，并尝试从那里运行python代码。但是，我遇到以下错误： 回溯（最近一次调用）：文件 “KafkaConsumer.p