chessplay opened a new issue, #8914:
URL: https://github.com/apache/seatunnel/issues/8914
Hi SeaTunnel community,
When using the Kafka Source with pattern-based topic subscription (e.g.,
topic = "^test-ogg-sou.*"), how can I include the source topic name in output
records?
My current configuration:
source {
Kafka {
topic = "^test-ogg-sou.*"
pattern = "true"
# ...其他配置...
}
}
Challenge:
Records from multiple matched topics (e.g., test-ogg-sou-orders and
test-ogg-sou-users) become indistinguishable after consumption.
What I need:
A way to preserve the source topic name in each record (e.g., a metadata
field like _topic).
--
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]
