《消息》专题

我正在使用Kafka0.8.0并尝试实现下面提到的场景。 JCA API（充当生产者并将数据发送到）------>消费者------>HBase 当我使用JCA客户端获取数据时，我会立即将每个消息发送给消费者。例如，一旦生产者发送第1号消息，我就想从消费者那里获取相同的消息并将其“放入”HBase。但是我的消费者在一些随机的n条消息之后开始获取消息。我想让生产者和消费者同步，这样他们两个开始一起工

全部的 我对RabbitMQ在消耗大量消息（例如280000条）时的性能有一个问题。从性能角度来看，它似乎会上下波动。从管理控制台获取的图中所示的图表演示了这一点，其中消费者平均每秒约40条消息，然后跳到每秒约120条消息： 该模式将再次重复，它将再次返回到40，然后再次返回120，依此类推，如果我在1小时后运行相同的测试，则会发生相同的上下效应，但范围可能会有很大差异，例如每秒140到400条消

虽然auto.offset.reset的值是最新的，但使用者从属于2天前的消息开始，然后就会赶上最新的消息。 我错过了什么？

主要内容：1 PullMessageService拉取消息,2 PullMessageService#pullMessage拉取消息,3 DefaultMQPushConsumerImpl#pullMessage拉取消息,3.1 pullKernelImpl拉取消息,3.2 pullMessage发起拉取消息请求,4 总结基于RocketMQ release-4.9.3，深入的介绍了DefaultMQPushConsumer消费者发起拉取消息请求源码。 此前我们学习了DefaultMQPushC

我们有一个制作人 在开发过程中，我重新部署了producer应用程序，并做了一些更改。但在此之后，我的消费者没有收到任何消息。我尝试重新启动消费者，但没有成功。问题可能是什么和/或如何解决？ 消费者配置： 生产者配置： 编辑2： 5分钟后，消费者应用程序死亡，但以下情况除外：

我使用一个生产者在本地主机上运行的Kafka服务器中输入了一些消息。Zookeeper也在本地主机上。我使用了这里给出的。 但是，消费者似乎没有收到任何消息！ 脚本可以提取所有这些消息，但代码不能。怎么了？消费者代码与该页面上给出的代码完全相同。 这是我发布消息的同一主题。以下是制作人的代码：

我们运行一个集群工作线程应用程序，该应用程序依赖于 Kafka 使用高级消费者 API 使用消息。群集中的所有节点共享同一个使用者组。现在我们想要的是将该逻辑的一部分迁移到 Kafka 流处理器 API。这里的方法是什么？如果分配了相同的 groupId/clientId，流拓扑是否会与现有使用者就消息进行斗争？我们应该分配不同的 groupId/clientId 吗？流式传输拓扑？说“组”。 “

我正在试验Spring Webflux和Spring集成，以从JMS队列创建反应流（Flux）。 我试图从JMS队列（使用Spring集成的IBM MQ）创建一个反应流（Spring Webflux），以便客户端异步获取JMS消息。我相信我已经把一切都正确地连接起来了，因为这些信息正被被动的听众所消耗。然而，我的反应流量流无法显示这些消息。任何帮助都将不胜感激。 这是我用来使我的JMS侦听器响应的

我正在为Kafka0.9.0.0做Kafka快速入门。 我让zookeeper在监听，因为我运行了 只有一个代理在处侦听，因为我运行了 我有一个制作人在主题“测试”上发帖，因为我跑了 当我运行旧的API使用者时，它通过运行 但是，当我运行新的API使用者时，我在运行时没有得到任何东西 是否可以使用新的API从控制台使用者订阅主题？我该怎么修好它？

我有一个简单的Spring boot应用程序，它基于Atomikos事务管理器的JTA。它使用队列中的消息并记录它们。问题是，在第7条传入消息之后，队列中的其余消息将被退出队列，但不会被处理。我意识到这种表现是循环的，我的意思是： 在队列中插入了10条消息 已处理并退出第一条消息的队列 已处理并退出第二条消息的队列 已处理并退出第三条消息的队列 已处理并退出第四条消息的队列 已处理并退出第5条消息

已使用生产者推送消息。它向主题推送了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

我将python kafka consumer的< code>auto_commit设置为< code>False，我正在手动提交消息。然而，重启后，消费者再次消费来自每个分区的最后一条消息。只有最后一个，不能再多。 这就是所展示的： 不知道为什么会显示滞后，whu当前偏移设置为最后一条消息而不是下一条？当我提交偏移量3时，当前偏移量不应该移动到4吗？ 我提交我使用的每条消息，但是在重启时，它总是

这是一个关于Kafka和信息如何被消费的非常基本的问题，但不幸的是，我在这一点上找不到任何答案。 假设我想过度分区，那么我将得到比消费者多10倍的分区。过度分区是必需的，因为我希望能够扩展(在未来并行处理更多的消息)。 1 个主题分为 1000 个分区，由 100 个使用者使用 =- 我的问题是： > 消息是如何为每个消费者消费的：它是以循环方式完成的吗？如果不是，分发是如何完成的？ 有没有保证消

如果一个主题订阅者在向该主题/订阅者发送推送通知时没有在线，那么他/她的消息会丢失还是当他们在线时才收到消息？