ASF GitHub Bot commented on FLINK-8983:

Github user dmpour23 commented on the issue:

    Hi would this work for KeyedDeserialization/KeyedSerializationSchema.
    Should the import be: 
    > org.apache.flink.api.common.serialization.DeserializationSchema

> End-to-end test: Confluent schema registry
> ------------------------------------------
>                 Key: FLINK-8983
>                 URL: https://issues.apache.org/jira/browse/FLINK-8983
>             Project: Flink
>          Issue Type: Sub-task
>          Components: Kafka Connector, Tests
>            Reporter: Till Rohrmann
>            Assignee: Yazdan Shirvany
>            Priority: Critical
> It would be good to add an end-to-end test which verifies that Flink is able 
> to work together with the Confluent schema registry. In order to do that we 
> have to setup a Kafka cluster and write a Flink job which reads from the 
> Confluent schema registry producing an Avro type.

This message was sent by Atlassian JIRA

Reply via email to