mongo-kafka
mongo-kafka copied to clipboard
Binary outbox pattern
I have added a new output format to allow for easy implementation of the outbox pattern used with micro services when database updates need to be in sync with messages sent to Kafka.
Format name: BINARY_OUTBOX
Properties:
- binary_outbox.document.topic: name of the property within the MongoDB document containing the Kafka topic name where to send the message to
- binary_outbox.document.key: name of the property within the MongoDB document containing the Kafka key that shall be used when sending the message
- binary_outbox.document.value: name of the property within the MongoDB document containing the actual message (any binary format - could be JSON, AVRO etc.)