• Groups
• com.cj
• kafka-rx_2.10
• 0.1.0

Artifact 'com.cj:kafka-rx_2.10:0.1.0'

reactive kafka consumer

'com.cj:kafka-rx_2.10:0.1.0'

<dependency>
	<groupId>com.cj</groupId>
	<artifactId>kafka-rx_2.10</artifactId>
	<version>0.1.0</version>
</dependency>

<dependency org="com.cj" name="kafka-rx_2.10" rev="0.1.0"/>

"com.cj", "kafka-rx_2.10", "0.1.0"

Dependencies

Compile dependencies

• io.reactivex » rxscala_2.10 » 0.23.0
• org.apache.curator » curator-framework » 2.7.0
• org.apache.curator » curator-recipes » 2.7.0
• org.apache.kafka » kafka_2.10 » 0.8.2-beta

Test dependencies

• org.apache.curator » curator-test » 2.7.0
• org.scalatest » scalatest_2.10 » 2.1.3