用于与Apache Kafka使用者API相关的问题
KafkaConsumer 0.10 Java API错误消息：没有分区的当前分配
我正在使用KafkaConsumer 0.10 Java api。我想从特定的分区和特定的偏移量消耗。我查了一下，发现有一个搜索方法，但它抛出异常。有人有......
我们有一个使用org.apache.kafka.clients.consumer.KafkaConsumer的Java应用程序消耗Kafka消息我们创建了一个Spring-Kafka依赖的Spring Boot应用程序，但是...
我在ubuntu 16.04机器上运行kafka_2.11-2.0.0。创建了一个主题，并从命令行界面向其生成了一些消息。从命令行开始消费，它消耗得很好。但......
setConsumerRebalanceListener如何获取使用者
我使用spring-kafka 1.1.3.RELEASE和kafka-clients 0.10.0.0并且我想在工厂中使用setConsumerRebalanceListener，但我不知道如何让使用者保存使用者分区。谢谢你......
如何使用直接流在Kafka Spark Streaming中指定使用者组
如何使用直接流API为kafka spark流指定使用者组ID。 HashMap中 kafkaParams =新的HashMap （）; kafkaParams.put（“metadata.broker ....
我知道我可以使用以下命令获取分配给分区的所有消费者：bin / kafka-consumer-groups.sh --bootstrap-server localhost：9092 --describe --group my-group这只会给消费者......
我想用python获得Kafka消费者群体列表，但我不能。我使用zookeeper python客户端（kazoo）但消费者组列表为空，因为这种方法对于老消费者而且我们没有使用...
不清楚Kafka中auto.offset.reset和enable.auto.commit的含义
我是Kafka的新手，我不太了解Kafka配置的含义，任何人都可以解释为什么更容易理解！这是我的代码：val kafkaParams = Map [String，Object]（“...
我正在将流媒体应用程序从水槽移动到kafka。我需要帮助，因为我是卡夫卡的新手。我有一台Windows机器，在某个特定位置由物联网传感器不断生成CSV文件......
我在侦听器方法中的Consumer类InventoryEventReceiver中收到以下错误。不确定出现NullPointerException的原因。我只是POST两个InventoryEvent对象....
我有一个消费者项目，它使用Kafka主题的数据。该流中90％的数据可以实时处理，但对于特定记录（~10％），我需要延迟处理。我是不是该 ...
如何在spring boot中动态地为每个主题创建单独的Kafka监听器？
我是Spring和Kafka的新手。我正在研究一个用例[使用SpringBoot-kafka]，允许用户在运行时创建kafka主题。春季申请预计将订阅这些......
对于具有单个分区的主题，具有相同group.id的多个使用者的预期行为
我有多个消费者都使用相同的group.id监听特定主题。该主题有一个分区。据我所知，来自同一消费群体的消费者（由......确定）
如何使用Apache Kafka生成/使用延迟消息？似乎标准的Kafka（和Java kafka-client）功能没有此功能。我知道我可以自己实现它......
我正在运行Kafka集群。示例代码：属性props = new Properties（）; props.put（ProducerConfig.BOOTSTRAP_SERVERS_CONFIG，“localhost：9092，localhost：...
org.apache.kafka.common.KafkaException：无法构造kafka使用者
我手动启动Zookeeper，然后是Kafka服务器，最后是Kafka-Rest服务器及其各自的属性文件。接下来，我在tomcat上部署我的Spring Boot应用程序在Tomcat中......
我的应用程序使用来自kafka主题的消息，当我在我的环境中运行单个实例时工作正常，但如果我运行多个实例，则说3个实例（高...
Kafka Consumer标记协调员2147483647死亡
我使用Kafka Server 0.9与消费者kafka-client版本0.9和kafka-producer 0.8.2。每件事情都很有效，除非我得到很多关于协调员死于消费者的信息......
第一次成立卡夫卡，卡夫卡0.11。使用几乎默认的配置。制作了一些消息给主题ABC。 2消费者被编码为使用来自同一主题的消息。每个......
如何阅读从主题到Spark Streaming的Kafka gzip压缩消息
我确实看到我们需要在生产者端进行更改以使用Gzip压缩，但我不确定如何在阅读消息时解压缩。请了解一下从哪里开始。 ...