用于与Apache Kafka使用者API相关的问题
我正试图找出目前的高级消费者正在努力解决的问题。我使用Kafka 0.8.2.1，在Kafka的server.properties中没有设置“offset.storage” - 我认为这意味着......
Kafka Consumer不断获取2天前每5分钟生成和消费的数据
我正在研究卡夫卡消费者，我注意到它正在消耗本应该在2天前消费的消息。它大约每5分钟重复这些消息，制作人不再......
在手动提交期间，特定偏移失败但是顺序提交的下一个偏移成功提交时会发生什么？
我正在使用轮询机制编写一个kafka使用者，其中每次轮询我收到100条消息。消费消息后，我逐个手动提交偏移量。在提交抵消时，有时......
kafka-console-consumer自定义反序列化器
我想在使用kafka-console-consumer.sh命令行工具时使用我的自定义value.deserializer。像这样：./ kafka-console-consumer --bootstrap-server kafka2：29092 --property ...
是否可以在kafka连接器中为kafka使用者组的主题重置偏移？
我的kafka接收器连接器读取多个主题（配置了10个任务），并处理来自所有主题的300个记录。根据每条记录中的信息，连接器可能......
因为它可以是标题的客人，有没有办法获取Java中特定主题的消费者列表？到目前为止，我能够获得像最终ListTopics结果这样的主题列表......
我们正在使用Kafka（版本0.8.2）实现消息传递解决方案。除了为Kafka Broker实施安全性之外，一切都很好。看起来有人知道kafka主机和端口能够......
我对卡夫卡很新。我正在创建两个主题，并从两个制作人发布这两个主题。我有一个消费者使用这两个主题的消息。这是因为我想......
我想知道，如果它存在一个消费者的属性，当kafka服务器无法设置应尝试连接到kafka服务器的次数。我也尝试过：....
我想在单个Kafka流应用程序中使用Processor API和DSL。此外，如何在单个应用程序中构建和运行多个拓扑（例如1使用处理器API和...
Kafka Consumer和Spark-Kafka-Consumer之间的区别
我有一个kafka主题，我通过Kafka Producer发送数据。现在在消费者方面，我有两种选择。 1.使用KafkaConsumer - 下面是kafkaConsumer的代码，它读取...
我正在阅读Alpakka的文档。在阅读Kafka消费者API时，我遇到了createDrainingControl（），我想知道这个函数有什么用？我明白 ...
我在ec2实例上设置了kakfa。我已为该实例分配了弹性IP地址。我能够启动动物园管理员和卡夫卡并创建主题。我无法从本地连接到经纪人......
我想确认Kafka Consumer配置是否正常工作。我将一些消费者属性值设置为非默认值（例如session.timeout.ms，heartbeat.interval.ms）。有没有 ...
从Kafka 0.11.0.1中的_transaction_state主题读取数据
我想读取事务的元数据（Kafka 0.11.0.1支持），以便我可以弄清楚是否已提交特定事务ID的事务。 ...
在生成或使用数据时我没有看到任何失败，但是生产中存在大量重复消息。对于一个获得大约100k消息的小主题，有大约4k重复...
我在用 org.apache.kafka 卡夫卡的客户端 2.0.1 ...
我有两个卡夫卡集群。我需要使用kafka-spring在它们之间实现一种同步。 [集群A，主题A] [集群B，主题B]我创建了监听器......
我是阿帕奇卡夫卡的新人。当我通过最新版本kafka_2.12-2.2.0 http://kafka.apache.org/quickstart进行快速入门指导时。我遇到了问题，无法通过...
我有一个kafka设置，包括prometheus的jmx导出器。我正在寻找一个指标，根据主题和groupid给出偏移滞后。我正在运行kafka 2.2.0。一些资源在线点......