【发布时间】：2016-10-13 00:43:12
【问题描述】：
如何将 Strom spout 设置为可靠
有没有要设置的属性
kafkaSpout 默认可靠吗
如何改变 kafkaSpout 中的可靠性
【问题讨论】：
【发布时间】：2016-10-13 00:43:12
【问题描述】：
Kafka 默认是可靠的。这是 PartitionManager 类的代码，它负责从 Kafka 主题中读取消息：
collector.emit(tup, new KafkaMessageId(_partition, toEmit.offset()));
如您所见，emit 方法的第二个参数是 KafkaMessageId。您可以以类似的方式在您的 spout 中传递消息 ID。消息id可以是普通整数。
【讨论】：
-
谢谢，顺便说一句，如何将我的 kafkaSpout 设置为不可靠......对于正常的 spout，还如何将其设置为可靠或不可靠。