You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Robert Metzger (JIRA)" <ji...@apache.org> on 2019/07/31 09:58:00 UTC

[jira] [Commented] (FLINK-13507) kafka consumer not able to distinguish topic name after add source

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