request offset commit after a successful flush() by jerrinot · Pull Request #28 · questdb/kafka-questdb-connector