[ 
https://issues.apache.org/jira/browse/FLINK-2597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14909152#comment-14909152
 ] 

Vimal commented on FLINK-2597:
------------------------------

a question.

which serializer should be used with KafkaProducer? the serializer used in the 
link you shared is under package io.confluent.* . i dont think i should add a 
dependency as
<dependency>
    <groupId>io.confluent</groupId>
    <artifactId>kafka-avro-serializer</artifactId>
    <version>1.0</version>
</dependency>
also, fails to fetch this dpendency
also, io.confluent avro serliazer doesnt send the schema, sends the schema url 
instead.

Guess i should write own simple avro serializer for this test

> 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)

Reply via email to