TengYao Chi created KAFKA-20203:
-----------------------------------
Summary: setFlushListener should pass record.headers() instead of
empty headers
Key: KAFKA-20203
URL: https://issues.apache.org/jira/browse/KAFKA-20203
Project: Kafka
Issue Type: Sub-task
Components: streams
Reporter: TengYao Chirefs: https://github.com/apache/kafka/pull/21451#discussion_r2807009527 https://github.com/apache/kafka/pull/21486#discussion_r2834880173 -- This message was sent by Atlassian Jira (v8.20.10#820010)
