On Thu, May 18, 2017 at 8:26 PM, Yuxiang Mai <[email protected]> wrote:
> 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
>
>
--
Yuxiang Mai
Sun Yat-Sen Unitversity
State Key Lab of Optoelectronic
Materials and Technologies
