我有一个消费者(实现ICommonConsumer)，它应该在接收消息时调用receive：我的问题是，一些用户发送classType CommonMessage.class的消息，一些用户发送他们自己定制的消息类型，比如CustomizedMessage我不知道我应该把这张唱片写成什么。CommonMe
浏览 16提问于2020-06-08得票数 0
这是我的消费者代码： props.put("group.id", "testgroup");
props.put("kafka.topic/kafka-server-
浏览 0提问于2016-04-03得票数 0
在Kafka中订阅Topic之前，如何获取所有消息都已发布？我使用Kafka 2.12-2.3.0 Producer发送消息，Consumer接收消息。实际上，我正在使用Kafka在java中构建一个聊天应用程序。但问题是，如果生产者发布了一些消息，而消费者后来订阅了，那么它就得不到这些消息。请给我一些建议。
浏览 15提问于2019-09-14得票数 0
Kafka 0.8.2：request.timeout.ms在将错误发送回客户端之前，代理将等待尝试满足request.required.acks要求的时间量。Kafka 0.11.0：request.timeout.ms配置控制客户端等待请求响应的最大时间。如果在超时之前没有收到响应，客户端将在必要时重新发送请求，或者在重试次数耗尽时使请求失败。
浏览 2提问于2017-09-15得票数 3
2回答
我们有一个应用程序，消费者读取消息，线程执行许多操作，包括在消息被生成到另一个主题之前访问数据库。在线程上消费消息和生成消息之间的时间可能需要几分钟。一旦向新主题生成了消息，就会执行一次提交，以指示我们已经完成了对消费者队列消息的处理。由于这个原因，自动提交被禁用。我使用的是高级消费者，我注意到zookeeper和kafka会话超时，因为我们在消费者</e
浏览 2提问于2014-12-20得票数 9
回答已采纳
2回答
Kafka保证有序投递和多订阅者。卡夫卡是怎么做到的？Q1:在这种情况下，哪个更好？请给我提个建议。即使我对JMS的看法是错的，请让我知道。
浏览 1提问于2017-03-08得票数 18
回答已采纳
1回答
我是kafka的初学者，已经开发了kafka消息的消费者，现在看起来很好。虽然在测试消费者时出现了一些需求，但这可能需要在消费者端对消息进行一些节流。消费者(.net核心，使用confluent)在接收到消息后，调用api，api处理该消息。作为这个过程的一部分，它对数据库的读写次数很少。场景是，消费者每天可能会收到数百万或至少几千条消息
浏览 12提问于2020-05-18得票数 0
我在本地服务器上安装了kafka，通过在服务器上运行的一些其他应用程序，生产人员正在将消息发布到我的kafka服务器内的代理，通过zookeeper，我可以很容易地看到我的kafka的健康状况，它显示了在我的kafka服务器中创建的所有主题，主题中的偏移量等等，所以zookeeper唯一不能显示的是单个主题中的消息，所以有人推荐kafka-manager工具，我安装并运行它，它工作得很好，它显示了来自我的ka
浏览 7提问于2016-08-19得票数 0
1回答
我想知道一个主题被消费的速度。在Kafka-manager指标中有Messages in /sec，但没有我想要的Messages out /sec。我该怎么办？
浏览 0提问于2018-12-21得票数 2
在我们的应用程序中，我们使用kafka消费者来决定发送电子邮件。该应用程序使用spring-
浏览 4提问于2019-10-26得票数 2
1回答
我希望在现有的系统中尝试使用Kafka，以取代旧的消息协议。目前，我们有许多类型的消息(数百条)用于在大约40个应用程序之间进行通信。有些是高速率异步的，有些是基于用户/事件的请求。现在看看Kafka，它划分了主题和分区等，但我对主题的构成有点困惑。我的应用程序生成的每种类型的消息都有自己的主题，允许数百个主题，还是将它们聚集在一起，形成相关的消息类型？如果是第二个答案，那么当应用程序读取
浏览 18提问于2020-03-17得票数 0
回答已采纳
在使用消费者组控制消息传递时，如何保证同一消费者组内的每个消费者都能轮询接收消息？另外，Kafka使用的默认策略是什么，似乎所有的消息都可以一直发送给一个消费者？
浏览 0提问于2017-03-27得票数 1
我正在尝试将Flume与Kafka集成，我想将本地计算机上的一个文件传递给Flume，然后再传递给Kafka。我想在Kafka Consumer中查看我的文件内容。下面是我在Flume中的配置文件： #a1.sinks.k1.type = logger
a1.sinks.k1.type =
浏览 0提问于2015-11-04得票数 1
我在本地运行了我的动物园管理员和3个kafka代理。我启动了一个生产者和一个消费者。我可以看到消费者正在消费消息。然后，我启动了三个具有相同消费者组名称的消费者(由于这是一个spring启动项目，所以端口不同)。但我发现所有的消费者现在都在消费(接收)消息。但我希望消息是负载平衡的，因为只有消息不会在消费者之间重复。我不知道问题出在哪里。这是我的
浏览 3提问于2016-09-29得票数 0
我正在使用Micronaut应用程序来接收和返回apache Kafka的反应类型。来自Micronaut文档https://micronaut-projects.github.io/micronaut-kafka/latest/guide/ 有一种接收和返回反应类型的方法，如下所示System.out.println("Got Product - " + product.getName() + "
浏览 18提问于2020-11-09得票数 0
我在服务器启动时启动Kafka consumer。如果Kafka集群长时间(几个小时)宕机，对消费者会有什么影响？Kafka再次上线后会收到消息吗？
浏览 46提问于2019-12-12得票数 0
我正在使用kafka控制台工具，并试图设置它，如果至少有一个kafka服务器实例仍然在线，仍然可以发送和接收消息，同时使用复制。，则无论kafka2状态如何，发送和接收消息都是正常的。但是，如果kafka1离线而kafka2在线，发送的消息就会被交换--抵消增加，但在kafka1恢复在线之前，consumer1和consumer2中的任何一个都无法读取。在我看来，
浏览 6提问于2017-02-28得票数 0
回答已采纳
kafka消费者正在从另一个主题中读取关于主题1中的数据处理是否成功或失败的信息，即主题2是否成功或失败。我正在启动我的消费者，然后将数据发布到主题1。.I想使生产者和消费者同步，即一旦生产者发布数据，消费者应该读取该数据的成功或失败消息，然后生产者应该继续处理下一组数据。
浏览 3提问于2017-08-01得票数 2
我有一个用例，我想在kafka之上实现同步请求/响应。例如，当用户发送HTTP请求时，我希望在特定的kafka输入主题上生成一条消息，该消息触发数据流，最终生成输出主题上的响应。为了实现这种情况，在接收到第一个HTTP请求时，我希望能够动态创建一个将从输出主题中消费的使用者，然后生成关于输入主题的消息。否则，输出主题上的消息可能会“丢失”。在我的例子中，由于应用程序的原因，消费者有一个随机
浏览 4提问于2022-11-15得票数 0
1回答
我想知道如何通过java api在kafka中获取每个主题的消息数，我不知道如何使用下面提到的命令行工具。你知道怎么做吗？PS:我不想通过循环通过KAFKA消费者流来计算计数，我试图在开始时计算这个计数(在从Kafka消费之前)
浏览 1提问于2016-08-06得票数 0
云服务器
ICP备案
实时音视频
对象存储
云直播
腾讯云开发者
