fqaiser94 opened a new pull request, #148: URL: https://github.com/apache/flink-connector-kafka/pull/148
_Haven't been able to file a JIRA ticket yet as I'm waiting on account creation._ Currently PyFlink users have access to only the `set_value_only_deserializer` API for configuring how to deserialize Kafka messages. This API is extremely limited as it does not allow PyFlink users to: 1. Deserialize keys 2. Access `ConsumerRecord` metadata such as topic, partition, offset, etc. We can resolve this by exposing a `set_deserializer` method which will allow users to pass in a `KafkaRecordDeserializationSchema` object that describes how to deserialize a `ConsumerRecord`. This is similar to the pattern followed by the Java implementation of `KafkaSourceBuilder`. -- 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]
