flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rmetzger <...@git.apache.org>
Subject [GitHub] flink pull request #2705: [FLINK-2597][FLINK-4050] Add wrappers for Kafka se...
Date Thu, 27 Oct 2016 15:05:33 GMT
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


If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.

View raw message