Details
-
Improvement
-
Status: Resolved
-
Minor
-
Resolution: Fixed
-
0.10.0, 0.9.4, 0.9.5, 0.9.6
-
None
-
CentOS 6 JDK1.7.0_75
Description
Storm KafkaSpout have a static class MessageAndRealOffset which is same with Kafka API 's kafka.message.MessageAndOffset . So I have remove MessageAndRealOffset and replace with MessageAndOffset