[ 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)