我正在编写一个web应用程序，用户可以在其中发送对Kafka消费者收到的消息的请求。为此，我尝试将Map对象放入会话中，然后在收到消息时将消息放入Map对象中。同时，在请求处理方法中，使用一个循环来检查Map是否填充了消息。现在的问题是，我不能设法获得消费者对象中的会话对象，所以它不能以这种方式工作。此外，如果
浏览 2提问于2017-07-18得票数 0
我对Kafka和阅读文档有点陌生。卡夫卡办公网站有一个。其中应用程序被绑定到一个主题，并且消息一到达就被处理。结果会回发到主题或数据库。Spring Kafka注解@KafkaListener具有相同的功能。例如，我尝试过。在这里，我们也会监听一个主题，并在发布内容时对其进行处理。
所以我很好奇地想知道1.这2个有什么不同?
浏览 5提问于2018-01-18得票数 1
我还可以通过ListConsumerGroupsResult list = AdminClient.listConsumerGroups()获取ConsumerGroups的列表。有没有办法从ListConsumerGroupsResult获取KafkaConsumer？通过我的IDE和在线搜索，我没有找到这样的方法，但我想知道社区中是否有人这样做过。
浏览 4提问于2018-10-18得票数 1
据我所知，kafka消费者只能使用API轮询()从代理中提取消息，但是我们知道我们也可以使用kafka高/low级别的使用者API从代理获取消息，那么kafka高/low级消费者API和API轮询()之间的关系是什么高/low级别的使用者API调用轮询()内部？
浏览 1提问于2017-05-15得票数 0
回答已采纳
我正在创建两个apache camel (blueprint XML) kafka项目，一个是kafka-producer，它接受请求并将其存储在kafka服务器中，另一个是kafka-consumer，它从kafka服务器获取消息并处理它们。但是，如何在同一个kafka topic中创建独立的消费群？如何在不同消费者组内的同一
浏览 28提问于2020-05-03得票数 1
我刚刚开始与卡夫卡合作，并开始在我的本地机器上玩卡夫卡。我能够使用confluent提供的生成和使用消息。
kafka客户端(即消费者和生产者)维护一个消息队列。生产者将把每条产生的消息存储在本地缓冲队列中。生产者需要显式地将消息从本地缓冲区推送到kafka集群。在消费者端，它将以某种方式从kafka集群中</e
浏览 0提问于2020-05-08得票数 0
回答已采纳
我有Spring-boot Kafka pub sub microserivces，如图所示。我想为我的每个应用程序做集成测试。在我的测试中，我想要发布一条消息到Topic X(用于Springboot--c)，该消息应该由处理并生成到Topic Y，我想确认该特定消息是否生成到主题的缺点：当我向主题X生成一条消息时，Springbo
浏览 73提问于2019-06-20得票数 1
1回答
我们是否可以在不汇集所有消息的情况下，从偏移量或持续时间内重新运行消息？如果是，请让我知道。我试过使用Kafka API，但它首先消耗所有消息，然后根据记录进行过滤。我的需求是发送一个偏移量作为输入以获取消息详细信息，或者发送自和结束日期/时间间隔以获取记录
浏览 4提问于2018-01-30得票数 0
自从我开始使用Kafka以来，我注意到Kafka正在广播每个消费者或群体的消息。如何让生产者只将消息发送给某个特定的消费者？我说的是一个主题系统谢谢
浏览 1提问于2018-01-04得票数 0
1回答
我在Databricks读了下面的博客
1.卡夫卡数据不断被火花工人/执行者中的卡夫卡接收者接收。使用了卡夫卡的高级消费者API。2.接收到的数据存储在Spark的worker/executor内存以及WAL中(在HDFS上复制)。卡夫卡接收机只在数据被保存到日志后才将卡夫卡的偏移信息更新给动物园管理员。现在我怀疑高级用户如何更新动物园管理员<em
浏览 1提问于2017-06-30得票数 1
2回答
我们在系统中有更多的服务，但为了简化我的问题，假设我有两种类型的服务，即工作节点和主节点。我希望它们都是可伸缩的。目前，他们通过kafka进行交流。我的问题:对于一个案例，我想从主节点发布一个事件(生成一个主题的消息)，并从所有工作节点获取该事件(从主题消费)。但是对于另一种情况，我需要向特定的工作节点发送消息。为了能够涵盖第一种情况，我的所有工作节点在k
浏览 1提问于2019-09-06得票数 0
我需要一些帮助来理解如何使用Spring boot、Kafka、Resilence4J来实现来自我的Kafka消费者的微服务调用。假设微服务关闭了，那么我需要使用断路器模式通知我的Kafka消费者停止获取消息/事件，直到微服务启动并运行。
浏览 26提问于2021-02-06得票数 0
1回答
我是kafka的初学者，已经开发了kafka消息的消费者，现在看起来很好。虽然在测试消费者时出现了一些需求，但这可能需要在消费者端对消息进行一些节流。消费者(.net核心，使用confluent)在接收到消息后，调用api，api处理该消息。作为这个过程的一部分，它对数据库的读写次数很少。场景
浏览 12提问于2020-05-18得票数 0
1回答
我的一个主要用例是解决基于特定id的消息/事件排序(就像Kafka世界中的partition key )。如何在Jetstream中完成此操作？ 我在Jetstream中遇到了去重键(Nats-Msg-Id)，但我认为这个功能与Kafka中的主题压缩更有同义词。我说的对吗？在Jetstream世界中，特定</e
浏览 216提问于2021-08-30得票数 5
我有一个从Spark processing到Kafka的实时流媒体数据。现在有了Kafka的输出，我想get the data from the Kafka using Flask..和visualize it using Chartjs或其他一些可视化工具..如何从Kafka using the python flask获取实时流数据？任何帮助都将不胜感激！
谢谢!
浏览 0提问于2016-02-05得票数 3
我正在使用apache camel集成我的kafka消息。此外，我还使用JAVA DSL来使用来自kafka端点的消息。使用apache kafka API，它知道如何提交具有给定属性切换的消费者偏移量。
如果我在camel-kafka组件中取消了自动提交，那么我如何在apcahe camel中提交偏移量呢？我使用下面的端点在Apache Cam
浏览 9提问于2015-09-21得票数 5
我们在AWS中有一个KAFKA设置，我们在那里发布来自发布者的消息，我们希望通过Kafka消费者从可以通过代理访问互联网的本地盒子中消费这些消息。在KAFKA消费者中是否有任何设置，以便我们可以更新代理详细信息。
注意:我们能够连接并从本地机器(Kafka消费者)获取消息，该机器可以直接访问互联网(无需代理)。
浏览 3提问于2018-05-09得票数 3
消费者收到一个Kafka流，流中的消息需要基于一些Validator Micro服务和Enricher API调用进行丰富和验证。它还将消息持久化到数据库中。流程是这样的- Kafka Stream consumer ->每个消息->调用Rule Validator Rest API ->调用富API<
浏览 0提问于2020-03-22得票数 1
当消费者实例group.id在重启时更改时，是否会对kafka性能产生任何影响。较旧的group.id将会发生什么情况?它是否仍然存在于代理内存中，或者何时将被删除？假设我有1000+消费者实例，并且所有实例都在重启时动态分配group.id。
可以为{log.retention.ms'}提供什么列表值。可以设置为1ms吗？
浏览 8提问于2018-08-28得票数 0
回答已采纳
云服务器
ICP备案
云直播
腾讯会议
实时音视频
腾讯云开发者
