flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-2597) Add a test for Avro-serialized Kafka messages
Date Thu, 27 Oct 2016 15:05:58 GMT

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

ASF GitHub Bot commented on FLINK-2597:

GitHub user rmetzger opened a pull request:


    [FLINK-2597][FLINK-4050] Add wrappers for Kafka serializers, test for partitioner and

    This pull requests addresses the following JIRAs:
    - [FLINK-2597
    Add a test for Avro-serialized Kafka messages](https://issues.apache.org/jira/browse/FLINK-2597)
    - [FLINK-4050 FlinkKafkaProducer API Refactor](https://issues.apache.org/jira/browse/FLINK-4050)
    The PR adds:
    - `KafkaSerializerWrapper` and `KafkaDeserializerWrapper` wrappers for using Kafka serializers
with Flink
    - A test case involving Confluent's `KafkaAvroSerializer` and `KafkaAvroDeserializer`.
They also use the schema registry from confluent (which I'm mocking with a simple test http
server in the test).
    - A test validating that we are properly calling Kafka partitioners with the producer
    - Documentation for everything mentioned above.

You can merge this pull request into a Git repository by running:

    $ git pull https://github.com/rmetzger/flink flink2597

Alternatively you can review and apply these changes as the patch at:


To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

    This closes #2705
commit 76365abb8ae378eaee3809ec050a09e266d745a2
Author: Robert Metzger <rmetzger@apache.org>
Date:   2016-10-26T18:48:21Z

    [FLINK-2597] Add wrappers for Kafka serializers, tests for Kafka partitioner and documentation


> 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: Batch Connectors and Input/Output Formats, Kafka Connector
>    Affects Versions: 0.10.0
>            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

View raw message