Skip to content

Instantly share code, notes, and snippets.

@xstefank
Last active October 19, 2019 19:57
Show Gist options
  • Save xstefank/0a456dfc3f6c03e4bc8e7349c1afaae9 to your computer and use it in GitHub Desktop.
Save xstefank/0a456dfc3f6c03e4bc8e7349c1afaae9 to your computer and use it in GitHub Desktop.
## Orders topic
mp.messaging.incoming.orders.connector=smallrye-kafka
mp.messaging.incoming.orders.topic=orders
mp.messaging.incoming.orders.bootstrap.servers=localhost:9092
mp.messaging.incoming.orders.key.deserializer=org.apache.kafka.common.serialization.StringDeserializer
mp.messaging.incoming.orders.value.deserializer=org.apache.kafka.common.serialization.StringDeserializer
mp.messaging.incoming.orders.enable.auto.commit=false
mp.messaging.incoming.orders.auto.offset.reset=earliest
mp.messaging.incoming.orders.group.id=baristas
## Queue topic
mp.messaging.outgoing.queue.connector=smallrye-kafka
mp.messaging.outgoing.queue.topic=queue
mp.messaging.outgoing.queue.bootstrap.servers=localhost:9092
mp.messaging.outgoing.queue.key.serializer=org.apache.kafka.common.serialization.StringSerializer
mp.messaging.outgoing.queue.value.serializer=org.apache.kafka.common.serialization.StringSerializer
mp.messaging.outgoing.queue.acks=1
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment