我无法从文档中找出哪个属性现在取代了consumer.timeout.ms =-1 (默认值)，后者在0.9之前的Kafka Consumer API版本中可用。有没有人有新文档的链接？我查找了Kafka文档，但没有成功。
浏览 12提问于2019-05-22得票数 1
我正在尝试用Apache构建管道: spooldir -> kafka通道-> hdfs接收器在等待Kafka的数据时超时
2016-02-26 18:25:17,125 (SinkRunner-PollingRunner-DefaultSinkProcessor-SendThread$KafkaTransaction.doTake(KafkaChannel.java:327)超时等待来自卡夫卡kaf
浏览 1提问于2016-02-26得票数 0
在卡夫卡，org.apache.kafka.clients.consumer.KafkaConsumer已经取代了SimpleConsumer。然而，它没有发送(.)函数。如何使用新的KafkaConsumer重写下面的代码？._import kafka.consumer.SimpleConsumerval <
浏览 3提问于2017-09-29得票数 1
回答已采纳
我找到了这个代码，它成功地读取了kafka主题，并在屏幕上打印了每条消息。我想扩展它来对字符串执行其他操作，而不仅仅是在屏幕上打印。为此，我想了解一下迭代消息的while循环中发生了什么。import kafka.consumer.ConsumerIterator;
public class ConsumerTest
浏览 0提问于2015-05-29得票数 3
kafka服务器和客户端jars移到最新库: 0.10.0.1consumer.timeout.ms is overridden to 100
dual.commit.enabled is overridden相同的异常，即使在设置dual.commit.enabled =
浏览 2提问于2017-04-11得票数 1
回答已采纳
1回答
我有一个使用者，它使用来自这两个主题的消息。这是因为我想根据优先级进行处理。有没有人知道如何从一个Kafka消费者的两个主题和两个流中阅读？
浏览 2提问于2015-06-10得票数 0
我注意到，自从Kafka 0.8.2.0以来，Kafka附带了一个新的maven模块：
<dependency>
<groupId>org.apache.kafka，它仍然提供了旧的maven
浏览 0提问于2018-07-21得票数 2
回答已采纳
我有一个Kafka应用程序，它可以创建多分区主题，填充它们，并与消费者一起阅读。这似乎很管用。
我试着去了解卡夫卡，所以我尝试了一些工具，比如卡夫卡经理和三人组。这些工具会告诉我我的主题，分区等，但似乎没有看到我的消费者为他们获得补偿。如果我用卡夫卡来看我的主题，我会看到我的主题加上一个__consumer_offsets，我认为这意味着卡夫卡(不是动物园管理员)在存储我的消费者。因为这是一个跨工具一致的问题，我想知道我是否在
浏览 1提问于2016-04-06得票数 0
我试图使用命令行工具-kafka-console- run . to为同一主题以不同的组名运行多个使用者。当我设置-组选项时，它会失败，错误是“组不是公认的选项”。在我升级到最新的kafka版本(kafka_2.11-0.8.2.2)之前，它一直运行良好。
浏览 3提问于2015-12-09得票数 5
回答已采纳
1回答
似乎要求您指定要连接到的ZooKeeper实例：但是，显然可以通过Java直接连接到KafkaString topic = "mytopic";
props.put("bootstrap.servers", "
浏览 3提问于2016-11-10得票数 3
回答已采纳
我使用卡夫卡0.8.2.1，no "offset.storage“设置在卡夫卡的server.properties中，我认为这意味着偏移存储在卡夫卡中。(我还通过检查Zk：/consumers/consumer_group_name/offsets/topic_name/partition_number中的路径，验证了动物园管理员中没有存储任何偏移量。我试着听__consumer_offsets主题，看看<em
浏览 10提问于2015-11-25得票数 37
回答已采纳
我在本地实现了带有手动偏移的高级消费者代码，但我有一个问题要问，假设如果我们不提交消息，是否有任何逻辑可以在不重新启动消费者的情况下再次读取该消息。如果我正在重新启动消费者，我能够获得该消息，但如何在不重新启动消费者的情况下获得该消息。
浏览 3提问于2016-01-29得票数 0
我使用[org.apache.kafka/kafka_2.10 "0.8.2.1"]作为依赖项，并且已经能够使用客户端API来设置一个KafkaProducer，该KafkaProducer发布带有纯字符串内容的消息我的问题是:在上是否有一个代码示例来演示如何初始化KafkaConsumer，并在另一边读取该消息，因为我已经搜索了好几天，而且似乎没有一个工作：
它们使用的类或方法甚至在API本身中都不
浏览 3提问于2016-05-19得票数 0
我希望在这里得到一些关于kafka连接配置属性的澄清，我很难理解如何理解前缀，以及connect如何提取和使用属性。我假设kafka conne
浏览 0提问于2019-09-04得票数 0
我正在按照快速入门指南上的说明在本地运行kafka。然后，我在config/consumer.properties中定义了我的使用者组配置，以便我的使用者可以从定义的group.id中挑选消息bin/kafka-consumer-groups.shconsole-consumer-67807 <-- when connecting to
浏览 1提问于2020-05-13得票数 5
回答已采纳
我在卡夫卡身上发现了很奇怪的东西。我有一个有三个经纪人的制片人：然后我尝试使用新的API运行一个使用者：
bin/kafka-console-consumer.sh --bootstrap
浏览 6提问于2017-03-28得票数 1
回答已采纳
使用kafka API访问它
使用消费群体属性=新属性()；properties.put(CommonClientConfigs.SECURITY_PROTOCOL_CONFIG，(SaslConfigs.SASL_JAAS_CONF
浏览 0提问于2019-02-17得票数 0
我正在使用Spring kafka开发一个spring boot应用程序，它可以监听kafka的单个主题，然后分离各个类别的记录，从中创建一个json文件，并将其上传到亚马逊网络服务S3。我在Kafka主题中收到了大量的数据量，我需要确保json文件被分成适当的大块，以限制上传到S3的json的数量。 kafk
浏览 1提问于2019-03-27得票数 1
回答已采纳
云服务器
ICP备案
腾讯会议
云直播
对象存储
腾讯云开发者
