[
https://issues.apache.org/jira/browse/FLINK-13507?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16896999#comment-16896999
]
Robert Metzger commented on FLINK-13507:
----------------------------------------
Thanks a lot for opening this ticket.
This has been solved as part of FLINK-8354. Through the {{ConsumerRecord}} you
can access timestamp, topic, offset etc. of each record in the deserialization
schema.
I'm closing this ticket.
> kafka consumer not able to distinguish topic name after add source
> ------------------------------------------------------------------
>
> Key: FLINK-13507
> URL: https://issues.apache.org/jira/browse/FLINK-13507
> Project: Flink
> Issue Type: Improvement
> Components: API / DataStream, Connectors / Kafka
> Reporter: quanduoling
> Priority: Major
>
> right now , i cannot find a way to distinguish topic name after add kafka
> source when spark streaming is able to, can flink add this feature to make
> kafka consuming more powerful and flexible
--
This message was sent by Atlassian JIRA
(v7.6.14#76016)
