《中邮消费金融》专题

问题内容： 我是一名学习Kafka的新学生，在了解多个消费者（到目前为止，文章，文档等对他们没有太大帮助）方面，我遇到了一些基本问题。 我尝试做的一件事是编写我自己的高级Kafka生产者和消费者并同时运行它们，将100条简单消息发布到某个主题，然后让消费者检索它们。我已经成功地做到了这一点，但是当我尝试引入另一个使用者来使用与刚刚发布消息的主题相同的主题时，它没有收到消息。 据我了解，对于每个主题

问题内容： 可用的库是sarama（或其扩展sarama- cluster ），但是没有提供消费者群体示例，在sarama或sarama-cluster中均未提供。 我不了解API。我可以举一个为主题创建消费者组的示例吗？ 问题答案： 消费方组由集群消费方“构造函数”的第二个参数指定。这是一个非常基本的草图： 因此，您将拥有一个属于指定消费者组的消费者。

我正处于探索Kafka0.8.1.1版本的初始阶段。 使用API进行触发器再平衡 将kafka配置为等待消费者活动一段时间，并假设它被不优雅地关闭，自动重新平衡。 这里的问题是，分配给死亡使用者的分区中的所有消息都保留在队列中，并且在重新平衡发生之前不会被处理。

我知道可以使用多个线程使用SQS队列。我想保证每封邮件都会被消费一次。我知道可以更改消息的可见性超时，例如，等于我的处理时间。如果我的进程花费的时间超过可见性超时时间（例如连接速度慢），则其他线程可以使用相同的消息。 保证消息只处理一次的最佳方法是什么？

我有一个问题，来自一个消费群体的许多Kafka客户端没有正确关闭，因此Kafka集群认为它们仍然是连接的。因此，我无法使用新版本的客户端连接到消费者组。会卡在再平衡这一步。 根据文档，应在< code>session.timeout.ms或maximum < code > group . max . session . time out . ms 之后删除它们。起初我试图将< code>sessi

我有一个单一的消费者在消费一个话题。主题有6个分区。分配给该组的单个使用者。我会像下面的那样进行轮询，当没有记录返回时，我会退出使用者提取。 从文档来看，我相信当没有记录要消耗时，轮询返回空，并且持续时间10000足以重新平衡和获取记录。大多数情况下，poll从所有分区中消耗记录，但有些情况下，poll从3个分区中提取记录并返回空记录而不消耗其他3个分区。 顺便说一句，我使用的是2.0.1的Kaf

如何以以下形式发送消息： 用Spring邮件？

我有多个制作人，可以向一个Kafka主题发送多种类型的事件。 我有一个消费者，它必须消费所有类型的消息。每种类型的消息都有不同的逻辑。 但在这种情况下，所有消息都指向此方法，不仅是EventOne 如果我实现了两种方法（对于每种类型的消息），那么所有消息都只能使用一种方法。 如果我像这样实现监听器： 然后我得到一个例外：org。springframework。Kafka。KafkaListener

我必须记录消费者在SpringKafka中花费的时间。由于kafkaListener方法对每条消息都执行，因此在那里放置一个记录器是行不通的。此外，有时一些信息会丢失，而不是被消费者消费掉。我应该把记录器放在哪里，以找出消费者启动后的弹性时间。使用者不会退出或关闭，其轮询将无限期进行

已使用生产者推送消息。它向主题推送了100000条消息。 使用命令：bin/kafka producer perf test。sh--代理列表localhost:9092--消息100000--主题perfAtlasTopic获取以下生产者指标。 开始时间，结束。时间、压缩、消息。大小，批次。大小，总计。数据发送。在里面MB，MB。秒，总计。数据发送。在里面nMsg，nMsg。第[2015-02-

我有一种在shell中执行此任务的方法：如何使kafka消费者从上次消耗的偏移量读取，而不是从开始读取 但是，我愿意在Python中这样做，使用 我找不到任何关于这种情况的api。 http://kafka-python.readthedocs.io/en/latest/apidoc/KafkaConsumer.html

嗨，我有一个简单的管道工作，应该发送一封邮件，我对管理詹金斯配置- 错误： 有什么建议可以解决吗？ 谢谢，

给定以下设置： Kafkav0.11.0.0 3个经纪人 2个主题，每个主题有2个分区，复制因子为3 2个消费者组，每个主题一个 3个包含使用者的服务器 服务器包含两个使用者，每个主题一个，这样： null null null 消费者-B1被分配到topic-1分区-1 消费者-C1被分配到topic-1分区-0 消费者-A1没有分配给分区 这似乎正如我们所料。由于分区计数为2，我们只有两个活动消

我们启动一个Kafka消费者，监听一个可能还没有创建的主题（不过，主题自动创建是启用的）。 此后不久，一位制作人发表了关于这个话题的消息。 Kafka原木

环境 springboot, rocketmq, nacos, feign 定义 [消费服务 A], rocketmq 消费服务, 触发任务处理 [数据服务 B], 本地数据库, 相关业务逻辑 [分析服务 C], 对接三方服务, 发送本地数据, 返回结果. 三方结果有同步, 有异步. 流程 [消费服务 A]触发事件, [数据服务 B]提供数据, 状态更新. [分析服务 C]通过第三方处理数据, 返