1回答
我正在使用简单的Kafka客户端API。据我所知，消费消息有两种方式，订阅主题和将分区分配给消费者。 config.put("bootstrap.servers", bootstrap);
config.put("group.id", KafkaTestConstants.KAFKA_GROUP// subscrib
浏览 22提问于2017-03-10得票数 0
我使用Ubuntu服务器16.04来尝试使用Kafka。对于启动生产者和消费者控制台的命令，我使用以下命令。生产者控制台：消费者控制台：
bin/kafka-console-consumer.sh--zookeeper localhost:2181 --from-beginning --<em
浏览 1提问于2017-01-02得票数 12
我用的是弹力靴。我们有几个微服务，每个微服务都有许多实例。我在考虑使用像ibm mq这样的消息传递软件。如果微服务x发送了一个事件x.created。我开始了，但我认为为了做到这一点，我需要向两个队列发送消息
浏览 25提问于2019-11-25得票数 1
3回答
我在一个消费者组中有两个消费者，他们分配了相同的kafka主题分区。我希望从消费者B内部获得消费者A的最后一次读取偏移量。有什么想法，如何实现这一点？
浏览 2提问于2016-08-01得票数 7
回答已采纳
有一个Kafka服务器使用Kafka来存储消费者组的偏移量，我想知道__consumer-offsets topic是否会有一个针对已删除的消费者组的事件？或者我如何订阅此活动而不询问Kafka是否存在特定的消费群体
浏览 42提问于2020-09-12得票数 0
我有一个有很多分区的主题。我希望许多应用程序读取来自这个主题的所有消息。一些申请经常阅读，另一些则在午夜阅读。我怎样才能在卡夫卡实现这一点？
浏览 0提问于2018-10-19得票数 0
回答已采纳
但是，即使在多次重启之后，很少有kafka分区不是由任何flink工作者订阅的。org.apache.kafka.clients.consumer.KafkaConsumer assign Subscribed to partition(s): topic_name-13, topic_nametopic_name-11, topic_name-12, topic_name-13
org.apache.kafka.clients.c
浏览 10提问于2020-09-08得票数 1
回答已采纳
假设我有一个kafka主题，假设有大约10个分区，我理解每个消费者组在任何给定时间都应该有10个消费者阅读该主题，以实现最大的并行度。然而，我想知道在任何给定的时间点，对于一个主题可以处理的消费者群体的数量，是否有任何直接的规则。(在最近的一次采访中，我被问到了这个问题)。然而，只是想知道在给定的时间点上可以扩展多少个最大的消费者组(每个有10个消费者)？
浏览 0提问于2019-07-09得票数 7
我有200个Kafka用户，他们可以做这些事情中的任何一个，1.他们可以订阅200个不同的主题，并将消费敏感的消息。2.所有200个消费者可以订阅单个topic。问题: 1.创建200个或更多的topic是一个好的设计吗? 2.在第二个场景中，我们如何实现发布到topic的消息只根据某个参数发送给特定的消费者。
浏览 0提问于2020-04-09得票数 1
2回答
我以前没有使用过Kafka，我想知道如果消息是通过Kafka发布的，有哪些可能的方法来捕获这些信息？我不需要发布信息，只需要处理从Kafka publisher收到的数据。任何提示都会有所帮助。
浏览 3提问于2020-02-22得票数 0
我正在使用下面的命令来生成和创建消费者组，面临着没有创建消费者组的问题。你能帮帮我吗？kafka-producer-perf-test --topic test-one --throughput 1000 --record-size 50 --num-records 10 --producer-propsbootstrap.servers='localhost:9092' --producer.config producer.properties
kafka-consumer-perf
浏览 0提问于2020-06-11得票数 0
2回答
有没有办法让一个消费者消费所有主题？如果是，那么我们如何实现它呢？另外，Kafka将如何维护偏移量？请建议答案。
浏览 1提问于2016-09-19得票数 32
回答已采纳
我有一个新的消费者列表(python消费者)。我可以使用以下命令检索组：我可以为每个主题获取它们所连接的主题bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server localhost:9092 --describe --group TheFoundGroupId如
浏览 9提问于2017-12-21得票数 4
Kafka Consumer (org.apache.kafka:kafka-clients:2.3.0)应该使用一个分区消费来自topic的消息。该服务记录消费者订阅，但它不使用消息，也不会使用Official Apache Tools kafka-consumer-groups.sh出现在消费者组列表中。o.a.k.clients.consumer.KafkaConsumer - [Consumer clientId=consumer-1, gro
浏览 129提问于2020-06-15得票数 0
回答已采纳
1回答
我已经使用kafka-python库编写了一个python脚本，它将消息写入和读取到kafka中。我编写消息没有任何问题；我可以使用kafka控制台工具检索它们。我在我的消费者上有一个for，它在迭代的第一行冻结，永远不会返回。下面是我的代码： "my-topic",
bootstrap_serversvalue_deserialize
浏览 12提问于2020-03-02得票数 1
回答已采纳
使用apache-Kafka版本2.11-2.4.0。 我正在创建一个应用程序，我想在其中向同一消费者组中的所有订阅者(消费者)发布事件。但在许多地方，我发现Kafka向消费者群体广播消息。
浏览 23提问于2020-01-09得票数 1
回答已采纳
在Kafka中订阅Topic之前，如何获取所有消息都已发布？我使用Kafka 2.12-2.3.0 Producer发送消息，Consumer接收消息。实际上，我正在使用Kafka在java中构建一个聊天应用程序。但问题是，如果生产者发布了一些消息，而消费者后来订阅了，那么它就得不到这些消息。请给我一些建议。
浏览 15提问于2019-09-14得票数 0
我一直在使用@KafkaListener作为一类Kafka事件消费者，它必须具有唯一的ids，并且每个事件使用者都必须有一个具有非常特殊名称的单独组。}-${environemnt.id}-${application.name}-${kafka.......topic}-#{T(java.util.UUID).randomUUID().toString= "${kafka.group.id.prefix}-${environemnt.id}-${application.name}-${k
浏览 10提问于2021-05-31得票数 0
为了确保从头开始的所有数据都被使用，每次建立websocket连接时，我都会创建一个新的消费者组并订阅该主题 const Kafka = require('node-rdkafka')})const consumer = new Kafka.KafkaConsumer但是，当我尝试将
浏览 35提问于2021-11-13得票数 0
回答已采纳
云服务器
ICP备案
云直播
实时音视频
即时通信 IM
腾讯云开发者
