Skip to content

Latest commit

 

History

History
33 lines (26 loc) · 808 Bytes

README.adoc

File metadata and controls

33 lines (26 loc) · 808 Bytes

Groovy+Kafka+Protobuf Example

This repository contains an example Kafka consumer and producer written in Groovy that handle Protobuf encoded messages.

Usage

  1. Compile the .proto files into a JAR:

    cd proto && mvn package

    This will output proto/target/proto-0.1.1-SNAPSHOT.jar

  2. Run the consumer Groovy script:

    groovy -cp proto/target/proto-0.1.1-SNAPSHOT.jar groovy/src/consumer.groovy

  3. Run the producer Groovy script:

    groovy -cp proto/target/proto-0.1.1-SNAPSHOT.jar groovy/src/producer.groovy "Hello World"

If everything works correctly you should see message field from the ExampleMessage Protobuf displayed by the consumer:

groovy -cp proto/target/proto-0.1.1-SNAPSHOT.jar groovy/src/groovy/consumer.groovy
got message: Hello World