喷口内有msgid，用于确认和失败，问题是我能从螺栓内得到这个msgid吗？
tvz2xvvm1#
不，你只能得到这个螺栓处理的元组的msgid。如果您想获得源msgid和发出的喷口，您必须将id与消息一起发出。
6qfn3psc2#
我认为您不需要消息id。如果您使用的是storm kafka，则可以使用以下方案获得作为元组一部分发出的分区和偏移量https://github.com/apache/storm/blob/master/external/storm-kafka/src/jvm/org/apache/storm/kafka/stringmessageandmetadatascheme.java. 您可以将其设置为您的喷口配置的一部分。如果您使用的是storm kafka客户端，则默认情况下它会发出此信息https://github.com/apache/storm/blob/master/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/defaultrecordtranslator.java
2条答案
按热度按时间tvz2xvvm1#
不，你只能得到这个螺栓处理的元组的msgid。
如果您想获得源msgid和发出的喷口，您必须将id与消息一起发出。
6qfn3psc2#
我认为您不需要消息id。如果您使用的是storm kafka，则可以使用以下方案获得作为元组一部分发出的分区和偏移量https://github.com/apache/storm/blob/master/external/storm-kafka/src/jvm/org/apache/storm/kafka/stringmessageandmetadatascheme.java. 您可以将其设置为您的喷口配置的一部分。
如果您使用的是storm kafka客户端，则默认情况下它会发出此信息https://github.com/apache/storm/blob/master/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/defaultrecordtranslator.java