GitHub user brianghig opened a pull request:
https://github.com/apache/incubator-nifi/pull/55
[NIFI-413] PutKafka Compression and Batching Support
Adding properties to PutKafka processor to support asynchronous producing
with configurable batches.
Also added user-defined control over compression codec and compressed
topics per NIFI-413.
Producer Type remains synchronous by default.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/brianghig/incubator-nifi
NIFI-413-PutKafka-Compression-and-Batching
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/incubator-nifi/pull/55.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 #55
----
commit 29b4e56a61dc7125e10d7e5d70a0123485717b4d
Author: Brian Ghigiarelli <[email protected]>
Date: 2015-04-22T15:32:36Z
Merge pull request #1 from apache/develop
Merging latest NiFi to my fork
commit 421ad8fb133d3bab32bc20d98011e9dfa0caff99
Author: Brian Ghigiarelli <[email protected]>
Date: 2015-05-14T00:32:23Z
Merge pull request #2 from apache/develop
Merging latest Apache NiFi to fork
commit 9653770ac4a050f4439c07f7ae6e34658f08e5a0
Author: Brian Ghigiarelli <[email protected]>
Date: 2015-05-14T12:55:04Z
[NIFI-413] Adding properties to PutKafka to support asynchronous production
with configurable batching. Also added user-defined control over compression
codec and compressed topics. Producer type remains synchronous by default.
commit b71b51976eb6e5afba636c8dd16e33a7436e3999
Author: Brian Ghigiarelli <[email protected]>
Date: 2015-05-14T12:57:25Z
Merge pull request #3 from apache/develop
Merging in latest develop branch
----
---
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.
---
