• Groups
• com.cj
• kafka-rx_2.11
• 0.3.0

Artifact 'com.cj:kafka-rx_2.11:0.3.0'

reactive kafka consumer

'com.cj:kafka-rx_2.11:0.3.0'

<dependency>
	<groupId>com.cj</groupId>
	<artifactId>kafka-rx_2.11</artifactId>
	<version>0.3.0</version>
</dependency>

<dependency org="com.cj" name="kafka-rx_2.11" rev="0.3.0"/>

"com.cj", "kafka-rx_2.11", "0.3.0"

Dependencies

Compile dependencies

• io.reactivex » rxscala_2.11 » 0.25.0
• org.apache.curator » curator-framework » 2.8.0
• org.apache.curator » curator-recipes » 2.8.0
• org.apache.kafka » kafka_2.11 » 0.8.2.1

Test dependencies

• org.apache.curator » curator-test » 2.8.0
• org.scalatest » scalatest_2.11 » 2.1.3