Hi, expert We have upgraded our storm cluster to V.1.1.0 from 1.0.2. We are using TridentSpout for our topology, and change our external package from Storm-Kafka to Storm-Kafka-Client to be fit to the new Kafka API.
But in test, we found that our Topology working find with the KafkaTridentSpoutOpaque, it's just the same as the OpaqueTridentKafkaSpout in storm-kafka v.1.0.2. But for the KafkaTridentSpoutTransactional, it's very strange. Seems Storm-kafka-client 1.1.0 do not support KafkaTridentSpoutTransactional. Here is the code for org.apache.storm.kafka.spout.trident.KafkaTridentSpoutTransactional in v.1.1.0: *Is Storm-kafka-client no longer support KafkaTridentSpoutTransactional?* public class KafkaTridentSpoutTransactional implements IPartitionedTridentSpout { @Override public Coordinator getCoordinator(Map conf, TopologyContext context) { return null; } @Override public Emitter getEmitter(Map conf, TopologyContext context) { return null; } @Override public Map<String, Object> getComponentConfiguration() { return null; } @Override public Fields getOutputFields() { return null; } } Thanks a lot. -- Yuxiang Mai