GitHub user rmetzger opened a pull request:
https://github.com/apache/flink/pull/1082
[FLINK-2372] Add new FlinkKafkaProducer
This pull request is reworking Flink's KafkaSink.
I've renamed the class to `FlinkKafkaProducer` to match it with
`FlinkKafkaConsumer`.
It uses the new Kafka [Producer
API](http://kafka.apache.org/documentation.html#producerapi).
In the documentation, they recommend using the new Producer API:
> As of the 0.8.2 release we encourage all new development to use the new
Java producer. This client is production tested and generally both faster and
more fully featured than the previous Scala client.
I've also noticed a good performance gain while doing some benchmarks with
Flink and Kafka.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rmetzger/flink flink2372-second
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/1082.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 #1082
----
commit f042a6471f300e09894c521678a60aa144790134
Author: Robert Metzger <rmetz...@apache.org>
Date: 2015-08-28T12:33:49Z
[FLINK-2372] Add new FlinkKafkaProducer
----
---
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 infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---
