Skip to content

Latest commit

 

History

History
19 lines (15 loc) · 805 Bytes

README.md

File metadata and controls

19 lines (15 loc) · 805 Bytes
Raw

Configuratin

Make a copy of src/main/resource/ccloud-java-template.properties and fill the API-KEY data and Bootstrap server

Create a couple of topics for input and output data

Running TX Processor

./gradlew runTxOffsetConsumer -Pconfig=src/main/resources/ccloud-java.properties -Pin=input-topic -Pout=output-topic

Running Standard Processor

./gradlew runSyncOffsetConsumer -Pconfig=src/main/resources/ccloud-java.properties -Pin=input-topic -Pout=output-topic

Running Check

kafka-console-consumer --bootstrap-server <bootrap:9092> --consumer.config src/main/resources/ccloud-java.properties --topic output-topic --consumer-property "isolation.level=read_committed" --property print.partition=true --property print.offset=true --property print.key=true