Repository: storm Updated Branches: refs/heads/master 437c4b149 -> ee9e4fffb
STORM-697: Added tupleMetaData flag Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/5b4c28a0 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/5b4c28a0 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/5b4c28a0 Branch: refs/heads/master Commit: 5b4c28a088ffc62ebcc28e8c28a25d096aa1eb78 Parents: bc54e8e Author: matt.tieman <matt.tie...@inin.com> Authored: Tue Mar 3 11:46:30 2015 -0500 Committer: matt.tieman <matt.tie...@inin.com> Committed: Tue Mar 3 11:46:30 2015 -0500 ---------------------------------------------------------------------- external/storm-kafka/src/jvm/storm/kafka/KafkaConfig.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/5b4c28a0/external/storm-kafka/src/jvm/storm/kafka/KafkaConfig.java ---------------------------------------------------------------------- diff --git a/external/storm-kafka/src/jvm/storm/kafka/KafkaConfig.java b/external/storm-kafka/src/jvm/storm/kafka/KafkaConfig.java index 5c85983..9db0f5d 100644 --- a/external/storm-kafka/src/jvm/storm/kafka/KafkaConfig.java +++ b/external/storm-kafka/src/jvm/storm/kafka/KafkaConfig.java @@ -38,6 +38,7 @@ public class KafkaConfig implements Serializable { public long maxOffsetBehind = Long.MAX_VALUE; public boolean useStartOffsetTimeIfOffsetOutOfRange = true; public int metricsTimeBucketSizeInSecs = 60; + public boolean tupleMetaData = false; // True to generate tuples from MessageAndRealOffset, false to generate only from the message public KafkaConfig(BrokerHosts hosts, String topic) { this(hosts, topic, kafka.api.OffsetRequest.DefaultClientId());
