thehkkim commented on PR #10335:
URL: https://github.com/apache/seatunnel/pull/10335#issuecomment-3796653918
@och5351
Done! I've squashed all commits into a single commit with the title
matching the PR title: `[Feature][Connector-V2][Kafka] Add support for Kafka
message header`
@dybyte
Good suggestion! I've added an e2e test in KafkaIT to verify the headers
functionality.
The test (`testSinkKafkaWithHeaders`) verifies:
- Fields specified in `kafka_headers_fields` are correctly sent as Kafka
message headers
- These fields are excluded from the message payload
- Non-header fields remain in the payload as expected
Test file:
`seatunnel-e2e/seatunnel-connector-v2-e2e/connector-kafka-e2e/src/test/java/org/apache/seatunnel/e2e/connector/kafka/KafkaIT.java:299-336`
Config:
`seatunnel-e2e/seatunnel-connector-v2-e2e/connector-kafka-e2e/src/test/resources/kafka_sink_with_headers.conf`
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
