[GitHub] [flink] lamber-ken commented on issue #7781: [FLINK-8354] Add KafkaDeserializationSchema that directly uses ConsumerRecord

2019-03-05 Thread GitBox
lamber-ken commented on issue #7781: [FLINK-8354] Add KafkaDeserializationSchema that directly uses ConsumerRecord URL: https://github.com/apache/flink/pull/7781#issuecomment-469594239 @aljoscha, hi, the mismatch between KafkaDeserializationSchemaWrapper class's package name and file's loc

[GitHub] [flink] lamber-ken commented on issue #7781: [FLINK-8354] Add KafkaDeserializationSchema that directly uses ConsumerRecord

2019-03-04 Thread GitBox
lamber-ken commented on issue #7781: [FLINK-8354] Add KafkaDeserializationSchema that directly uses ConsumerRecord URL: https://github.com/apache/flink/pull/7781#issuecomment-469572614 @aljoscha hi, the java file was placed at wrong package [KafkaDeserializationSchemaWrapper.java](https