Compiler error when using OpaqueTridentKafkaSpout with Trident in Scala

[Milinda Pathirage <mp...@umail.iu.edu>]

Hi All,

I wrote some code to use OpaqueTridentKafkaSpout in a Trident topology
in scala. But I am getting compiler error below when I tried to create
a new stream using the OpaqueTridentKafkaSpout instance.

overloaded method value newStream with alternatives:
[error]   (x$1: String,x$2:
storm.trident.spout.IOpaquePartitionedTridentSpout[_, _ <:
storm.trident.spout.ISpoutPartition, _])storm.trident.Stream <and>
[error]   (x$1: String,x$2:
storm.trident.spout.IPartitionedTridentSpout[_, _ <:
storm.trident.spout.ISpoutPartition, _])storm.trident.Stream <and>
[error]   (x$1: String,x$2:
storm.trident.spout.ITridentSpout[_])storm.trident.Stream <and>
[error]   (x$1: String,x$2:
storm.trident.spout.IBatchSpout)storm.trident.Stream <and>
[error]   (x$1: String,x$2:
backtype.storm.topology.IRichSpout)storm.trident.Stream
[error]  cannot be applied to (String,
storm.kafka.trident.OpaqueTridentKafkaSpout)
[error]     val eventStream = indexingTopology.newStream("events", kafkaSpout)

Does some have any idea about this?

Thanks in advance
Milinda

-- 
Milinda Pathirage

PhD Student | Research Assistant
School of Informatics and Computing | Data to Insight Center
Indiana University

twitter: milindalakmal
skype: milinda.pathirage
blog: http://milinda.pathirage.org