The example code for configuring a KafkaSpout doesn't compile for me. I am
referencing 0.9.0-wip16a-scala292 and storm 0.8.2.  The sample code from
the storm-contrib/storm-kafka
<https://github.com/nathanmarz/storm-contrib/tree/master/storm-kafka>
doesn't match the parameter list for a new SpoutConfig.  The code in
TestTopology does build but the TransactionalTopologyBuilder is deprecated.

Is there a more up to date example code for building a topology using Kafka?

Should all topologies using a Kafka queue use Trident?

Thanks

Reply via email to