Landoop blogs code examples

• Time-Series with Kafka, Kafka Connect & InfluxDB blog

Execute

sbt run

To connect to the brokers, zookeepers and schema-registry as defined in application.conf

Build

sbt clean compile

To test

sbt clean test

To view dependency tree

sbt dependencyTree

To create a fat jar

sbt assembly

Deploy

Build an assembly and define the Brokers and the Schema Registry

sbt assembly

java -jar target/scala-2.11/avro-kafka-generator-assembly-1.0.jar \
     -brokers 127.0.0.1:9092 \
     -schema http://127.0.0.1:8081