[FLINK-5711] Deserialization schema that gives has full kafka log information

• Type: Improvement
• Status: Reopened
• Priority: Not a Priority
• Resolution: Unresolved
• Affects Version/s: 1.2.0
• Component/s: Connectors / Kafka
• Assignee: Unassigned
• Reporter: Mukesh Jha
• Created: 03/Feb/17 20:27
• Updated: 29/Jul/21 07:37

Description

I want to add a KeyedDeserialization schema that gives has full kafka log information

Current serializers don't have the topic partition offset information.