[
https://issues.apache.org/jira/browse/FLINK-2597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14740605#comment-14740605
]
Robert Metzger commented on FLINK-2597:
---------------------------------------
I don't think anybody is working on this.
I've assigned the issue to you.
The purpose of this issue is to make sure that Flink's Kafka Consumer is able
to read messages from Kafka serialized using Avro.
I think thats a common use case among industry users that should work properly
& out of the box with Flink.
Maybe adding a short paragraph into the documentation on how to use Avro with
Kafka would also be great (I would put it into the kafka.md file).
To test this, I would extend the KafkaITCase (consumer tests).
First, write avro serialized messages into a Kafka topic (maybe this is
helpful:
http://docs.confluent.io/1.0/schema-registry/docs/serializer-formatter.html)
without using any Flink code.
Then, read the data from the topic, using the FlinkKafkaConsumer, the
TypeInformationSerializationSchema and the AvroTypeInformation.
> Add a test for Avro-serialized Kafka messages
> ----------------------------------------------
>
> Key: FLINK-2597
> URL: https://issues.apache.org/jira/browse/FLINK-2597
> Project: Flink
> Issue Type: Bug
> Components: Avro Support, Kafka Connector
> Affects Versions: 0.10
> Reporter: Robert Metzger
> Assignee: Vimal
> Priority: Minor
>
> A user has asked for serializing Avro messages from Kafka.
> I think its a legitimate use-case that we should cover by a test case.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
