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)
