connect
connect copied to clipboard
Configure Kafka consumer isolation level
In the kafka input, the "isolation level" of the consumer should be configurable: https://pkg.go.dev/github.com/Shopify/sarama#IsolationLevel
This will enable Kafka inputs to correctly only process records that were committed, and hold off on consuming records part of an ongoing or aborted transaction.