-
3 votesanswersviews
消费者坚持重新加入
我已经阅读了其他主题并且通过使用新的组ID解决了这个问题,但是我想了解可能导致这种情况的原因 . 我有一个包含16个分区的主题,我设置了session.timeout.ms = 30000,并且max.poll.interval.ms = 30000000 . 我运行我的程序,然后按住它,所以它没有正常关闭 . 在我猜了16次后,我陷入了这个重新加入的问题 . session.timeout.m... -
0 votesanswersviews
订阅3个主题时,Kafka消费者未收到消息
我正在使用node-rdkafka(https://github.com/Blizzard/node-rdkafka)来使用和生成来自IBM Bluemix Message Hub的消息 . 我'm able to consume and produce messages without issue, as long as I only subscribe to a max of 2 topics... -
0 votesanswersviews
无法将消息发布到Message Hub
// Asynchronous response from Message Hub / Kafka. kafkaProducer.send(record, new Callback() { public void onCompletion(RecordMetadata m, Exception e) { if(e != null) { e.printStackTr... -
1 votesanswersviews
Kafka Producer 0.9性能问题与小消息
在发送小消息时,我们观察到Java Kafka Producer 0.9客户端的性能非常差 . 消息不会被累积到更大的请求批处理中,因此每个小记录都是单独发送的 . 我们的客户配置有什么问题?或者这是另一个问题吗? 使用Kafka Client 0.9.0.0 . 我们没有在Kafka未发布的9.0.1或9.1固定或未解析的列表中看到任何相关的帖子,因此我们专注于我们的客户端配置和服务器实例 .... -
4 votesanswersviews
消息中心上的Kafka Streams KTable配置错误
This issue is now solved on Message Hub 我在Kafka创建KTable时遇到了一些麻烦 . 我是Kafka的新手,这可能是我问题的根源,但我想我无论如何都可以问这里 . 我有一个项目,我希望通过计算它们的总发生次数来跟踪不同的ID . 我在IBM Cloud上使用Message Hub来管理我的主题,到目前为止它已经非常出色 . 我在Message Hub上... -
33 votesanswersviews
Apache Kafka客户端何时抛出“批量过期”异常?
使用Apache Kafka Java客户端(0.9),我正在尝试使用Kafka Producer class向代理发送一长串记录 . 异步send method会立即返回一段时间,然后在短时间内开始阻止每次通话 . 大约30秒后,客户端开始抛出异常(TimeoutException),消息为"Batch expired" . 什么情况导致抛出此异常? -
7 votesanswersviews
无法发送SSL关闭消息
我有一个线程,偶尔会在Message Hub上列出主题 . 但有一段时间,我得到了:无法发送SSL关闭消息 . 有任何想法吗? KafkaConsumer<String, String> consumer = new KafkaConsumer<>(getConsumerConfiguration()); try { Map<String, List<P... -
3 votesanswersviews
Kafka Streams在分组和聚合时使用KTable转换为字符串问题
我有一个Kafka流,其传入消息看起来像 sensor_code: x, time: 1526978768, address: Y 我想创建一个KTable,它存储每个传感器代码的每个唯一地址 . KTable KTable<String, Long> numCount = streams .map(kvm1) .groupByKey(S...