Skip to content

Instantly share code, notes, and snippets.

@danielkec
Last active June 22, 2020 19:40
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save danielkec/0cda08cd55f05b81a89213f409acdf53 to your computer and use it in GitHub Desktop.
Save danielkec/0cda08cd55f05b81a89213f409acdf53 to your computer and use it in GitHub Desktop.
Lets jump to simple example:
mp.messaging:
incoming.from-kafka:
connector: helidon-kafka
topic: messaging-test-topic-1
auto.offset.reset: latest
enable.auto.commit: true
group.id: example-group-1
outgoing.to-kafka:
connector: helidon-kafka
topic: messaging-test-topic-1
connector:
helidon-kafka:
bootstrap.servers: localhost:9092
key.serializer: org.apache.kafka.common.serialization.StringSerializer
value.serializer: org.apache.kafka.common.serialization.StringSerializer
key.deserializer: org.apache.kafka.common.serialization.StringDeserializer
value.deserializer: org.apache.kafka.common.serialization.StringDeserializer
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment