cloudevents
/
sdk-java
mirror of https://github.com/cloudevents/sdk-java.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity
sdk-java/examples/kafka
History
Pierangelo Di Pilato 81cbca5a3b
[2.3] Bump version to 2.3.1-SNAPSHOT (#441) 
Run:
```
./mvnw versions:set -DnewVersion=2.3.1-SNAPSHOT -DgenerateBackupPoms=false -B
```

Signed-off-by: Pierangelo Di Pilato <pdipilat@redhat.com>
 		2021-12-21 13:16:36 +01:00
..
src/main/java/io/cloudevents/examples/kafka fix: Update encoding for structured event (#384) 2021-05-03 09:39:48 +02:00
README.md Created kafka example (#194) 2020-07-02 09:25:43 +02:00
pom.xml [2.3] Bump version to 2.3.1-SNAPSHOT (#441) 2021-12-21 13:16:36 +01:00

README.md

Kafka + CloudEvents sample

Build

mvn package

Prepare a Kafka instance

You can use docker to start a sample kafka instance:

docker run --rm --net=host -e ADV_HOST=localhost -e SAMPLEDATA=0 lensesio/fast-data-dev

Produce events

mvn exec:java -Dexec.mainClass="io.cloudevents.examples.kafka.SampleProducer" -Dexec.args="localhost:9092 sample-topic"

Consume events

mvn exec:java -Dexec.mainClass="io.cloudevents.examples.kafka.SampleConsumer" -Dexec.args="localhost:9092 sample-topic"