Hi Johan,
Thank you for your reply and the information!
Now it's correctly worked!!
Leo
Johan Andrén於 2016年7月23日星期六 UTC+8下午5時53分21秒寫道：
>
> Hi Leo,
>
> What IntelliJ version and how did you open/import the Akka into IntelliJ?
> Make sure you have the latest as that works best, and just use Open
I am using reactive-kafka to stream data to an Akka cluster which processes
it. This is how the code looks like:
val consumerProperties = // Kafka consumer properties
var consumerWithSink = new
ReactiveKafka().consumeWithOffsetSink(consumerProperties)
Source.fromPublisher(consumerWithSink.pub
