pawel-big-lebowski opened a new pull request, #171: URL: https://github.com/apache/flink-connector-kafka/pull/171
With an implementation of lineage interfaces, Kafka source and sink provide `TypeDatasetFacet` which contains type information of data processed. This was working with extracting type information from `SerializationSchema`: ``` TypeExtractor.getParameterType(SerializationSchema.class, valueSerialization.getClass(), 0) ``` However, this ain't working for `ConfluentRegistryAvroSerializationSchema` due to type erasure. As a workaround, `TypeDatasetFacet` can be extended to contain `SerializationSchema` when direct extraction of `TypeInformation` is not possible. This allows handling this case on the lineage listener side, while keeping flink-connector-kafka unaware of Avro type extraction logic. -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
