[jira] [Created] (FLINK-20158) KafkaSource does not implement ResultTypeQueryable

[Shang Yuanchun (Jira)]

Robert Metzger created FLINK-20158:
--------------------------------------

             Summary: KafkaSource does not implement ResultTypeQueryable
                 Key: FLINK-20158
                 URL: https://issues.apache.org/jira/browse/FLINK-20158
             Project: Flink
          Issue Type: Bug
          Components: Connectors / Kafka
    Affects Versions: 1.12.0
            Reporter: Robert Metzger
             Fix For: 1.12.0


As a user of the new Kafka Source introduced in (FLINK-18323), I always have to specify the return type:

{code}
DataStream<Event> events = env.fromSource(source, WatermarkStrategy.noWatermarks(),
                        "Kafka Source").returns(TypeInformation.of(Event.class));
{code}

The old Kafka source implementation implements {{ResultTypeQueryable}}, which allows the DataStream API to get the return type from the deserializer.
The new Kafka Source also should have access to the produced type from the deserializer to forward it.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)