卡夫卡喷口整合

作者: ࿏自ོ༾由ོ༽人͙⃡⌇
发布时间: 2024-12-10 06:45:51 (1月前)
转自：

3 条回复

0#
回复此人
Let us fly | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> 在你的替代方法中，你可能会得到 <code> CommitFailedException </code> 由于： </p> <pre> <code> props.put(KafkaSpoutConfig.Consumer.ENABLE_AUTO_COMMIT, "true"); </code> </pre> <P> 风暴2.0.0-SNAPSHOT（以及1.0.6） - <EM> KafkaConsumer自动提交不受支持 </EM> </p> <P> 来自文档： </p> <BLOCKQUOTE> <P> 请注意，KafkaConsumer自动提交不受支持。该如果是，KafkaSpoutConfig构造函数将抛出异常设置“enable.auto.commit”属性，并使用该消费者 spout将始终将该属性设置为false。你可以配置通过setProcessingGuarantee自动提交的类似行为 KafkaSpoutConfig构建器上的方法。 </p> </BLOCKQUOTE> <P> 参考文献： </p> <UL> <LI> <a href="http://storm.apache.org/releases/2.0.0-SNAPSHOT/storm-kafka-client.html" rel="nofollow noreferrer"> http://storm.apache.org/releases/2.0.0-SNAPSHOT/storm-kafka-client.html </A> </LI> <LI> <a href="http://storm.apache.org/releases/1.0.6/storm-kafka-client.html" rel="nofollow noreferrer"> http://storm.apache.org/releases/1.0.6/storm-kafka-client.html </A> </LI> </UL> </DIV>

编辑
1#
回复此人
v-star*위위 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> Storm-kafka使用普通的kafka客户端在zookeeper中将消费者信息写入不同的位置和不同的格式。所以你无法在kafkamanager ui中看到它。 </p> <P> 你可以找到一些其他的监控工具，比如 <a href="https://github.com/keenlabs/capillary" rel="nofollow noreferrer"> https://github.com/keenlabs/capillary </A> 。 </p> </DIV>

编辑

登录后才能参与评论