我正在尝试理解在卡夫卡主题中是否有可能找到具体的信息。Kafka消息密钥被认为是解决这个问题的手段。 但我怀疑，该键只允许标识主题中的分区，而不是分区中的特定消息。有没有办法识别Kafka分区中的特定消息，并找到此消息以供进一步使用(例如，读取此特定消息)？
浏览 26提问于2021-01-28得票数 2
有没有一种优雅的方式来查询特定记录的Kafka主题？我正在构建的REST API获得一个ID，并且需要在Kafka主题中查找与该ID相关联的记录。一种方法是通过自定义消费者检查主题中的每条记录，并查找匹配的记录，但我希望避免读取大量记录的开销。Kafka有没有快速内置的过滤功能？
浏览 3提问于2016-03-01得票数 19
回答已采纳
我有一些概念上的障碍。[Kafka Topic]
[Kafka] ---????可以以请求/响应的方式使用Kafka吗？也就是说，Web层是否可以将消息<
浏览 0提问于2016-03-07得票数 1
我有一个kafka主题，在这个主题中，我必须使用Java查找主题中显示的消息数量和出现在主题中的分区数
浏览 5提问于2021-07-28得票数 0
回答已采纳
1回答
我有一个Spring应用程序，它使用几个Kafka主题进行进一步处理，并最终推出一个DB。它还有Kafka流，它从每个主题中过滤特定类型的事件，并统计每种特定类型的事件已经产生了多少。我还需要知道我的应用程序已经消耗了多少这些事件(每种特定类型的事件)。流可以很好地计算主题中有多少事件(也就是已经生成)，但是对于使用的消息，我也
浏览 1提问于2022-04-21得票数 0
我使用的是Axon版本(3.3)，它在SpringBoot主类中使用在我们的用例中，命令端微服务需要从kafka主题中挑选消息，而不是将其公开为Rest api。它会将事件存储在事件存储中，然后将其移动到另一个kafka主题，供查询端微服务消费。
由于KafkaAutoCOnfiguration被禁用，我不能使用spring-kafka
浏览 18提问于2019-07-12得票数 0
我正在尝试在给定的Kafka主题中绘制每单位时间(分钟或小时)接收的新消息的数量。 我曾经看到过关于在一个主题中查找当前消息数量的帖子。作为一个潜在的解决方案，我可以在每个时间间隔查询这个数字，但是，这不会考虑过期的消息(由于保留时间)。 有没有办法获取单位时间内kafka主题接收的新消息数量？
浏览 7提问于2019-03-14得票数 0
有一个Kafka服务器使用Kafka来存储消费者组的偏移量，我想知道__consumer-offsets topic是否会有一个针对已删除的消费者组的事件？或者我如何订阅此活动而不询问Kafka是否存在特定的消费群体
浏览 42提问于2020-09-12得票数 0
除了滞后之外，有没有办法识别多分区主题中的每个分区和多个消费者的最后一个kafka消息？
我知道一种识别最后一条消息的方法，那就是通过AdminClient API/。但需要使用不同的方法。
浏览 7提问于2022-11-26得票数 0
1回答
如何阅读来自Kafka topic on demand的消息。我有主题名称，offsetId，PartitionID，使用这三个参数，我如何从Kafka主题中检索特定的消息。可以使用Spring Kafka吗？我使用的是spring boot 2.2.4.RELEASE
浏览 0提问于2020-11-10得票数 0
我遇到过用于JBPM的Kafka WorkItem (7.18.0)，用于将消息发布到kafka主题。 但是，当topic中有消息时，如何触发特定的工作流呢？或者，如果主题中有一条消息，该过程如何恢复
浏览 16提问于2019-05-02得票数 0
1回答
我正在学习kafka，我想把我的应用程序分成两个微服务。首先，将所有传入的消息从KafkaConsumer保存到数据库，然后根据给定的id选择entity。第二，提供REST来保存和获取实体。他们之间的互动提供了卡夫卡。如何使用kafka从REST中的db接收存储的ID？这是在POST请求时调用生产者的示例代码。String, byte[]> result = resultFuture.get();
L
浏览 2提问于2017-11-28得票数 3
回答已采纳
我的输入是1:45$，我们正在处理消息，接下来我将更新1:null。我希望输出是相同主题中的1:null。我使用了这个代码：
kafka-topics --create --zookeeper zookeeper:2181 --topic latest- product-price --replication-factorconfig "delete.re
浏览 6提问于2019-12-10得票数 1
问题是，当我以编程方式向我的列表中添加一个新的SPListItem并为主查找字段设置SPLookupValue (这很好)之后，当我转到我的SharePoint门户中的list视图时，我会看到主字段中的值，但是当我在列标题中单击绿色的“刷新外部列表中的数据”图标，将数据从外部列表加载到辅助字段中时，我会得到以下消息。此外，当我试图编辑主外部查找列中显示的值(应该是
浏览 10提问于2013-11-26得票数 1
回答已采纳
1回答
据我所知，kafka source通过streamname-kafka-offsets主题维护MyCompositeModule使用的消息的偏移量(这是一个接收器，因为它是通过'module compose这是不可读的，如果有一种方法可以从这个主题中读取数据，我将不胜感激。
此外，当我从kafka源推送消息时，消息在redis传输中排队，然后模块从这个队列中获取它们。如果kafka消费者模
浏览 0提问于2015-12-18得票数 1
4回答
场景： 我正在将数据JSON对象数据写入kafka主题，而读取时我只想读取基于消息中存在的值的特定消息集。我使用的是kafka-python库。示例消息： {flow_status: "completed", value: 1, active: yes}
{flow_status:"failure",value 2, active:yes} 在这里，我只想读取flow_Status为已完成<em
浏览 78提问于2019-02-18得票数 2
回答已采纳
来自kafka的消息看起来像这样，但带有更多字段{"event":"eventapi", "source":"event2", "payload"
浏览 10提问于2017-10-24得票数 5
1回答
我编写了一个kafka-streams应用程序，它使用该主题，找到具有相同相关ID的A和B，并将它们聚合到一个新的消息C中，并将它们放在输出主题目的地上。有时，没有B的A(或明智的相反)会把源主题放在上面。我已经创建了一个可查询的状态存储库，所以我可以查看这些悬空消息，但是现在我想从中间主题中删除一条特定的消息。我猜这只是一个用正确的键得到消息<
浏览 0提问于2018-02-26得票数 1
2回答
我使用的是kafka_2.12版本2.3.0，其中我使用分区和键将数据发布到kafka主题中。我需要找到一种方法，可以使用键和分区组合来使用来自主题的特定消息。这样，我就不必使用所有的消息并迭代正确的消息。
浏览 5提问于2019-11-06得票数 3
回答已采纳
云服务器
ICP备案
腾讯会议
云直播
对象存储
腾讯云开发者
