GitHub user rmetzger opened a pull request:
https://github.com/apache/flink/pull/2705
[FLINK-2597][FLINK-4050] Add wrappers for Kafka serializers, test for
partitioner and documentation
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:
https://github.com/apache/flink/pull/2705.patch
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 <[email protected]>
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 [email protected] or file a JIRA ticket
with INFRA.
---
