Mark Payne
|
78b69f10dc
|
NIFI-8404: Added capability to rollback on failure for PublishKafka(Record)_2_0 and _2_6
NIFI-8404: Added unit tests for new Failure Strategy property
This closes #4982.
Signed-off-by: Peter Turcsanyi <turcsanyi@apache.org>
|
2021-04-08 17:47:13 +02:00 |
|
Mark Payne
|
74ea3840ac
|
NIFI-8357: Updated Kafka 2.6 processors to automatically handle recreating Consumer Lease objects when an existing one is poisoned, even if using statically assigned partitions
This closes #4926.
Signed-off-by: Peter Turcsanyi <turcsanyi@apache.org>
|
2021-03-24 14:59:13 +01:00 |
|
Joe Witt
|
88fab00e29
|
NIFI-7873 merging release branch to latest and updating to 1.14.0-SNAPSHOT
|
2021-02-15 12:09:32 -07:00 |
|
Joe Witt
|
4afb2ba743
|
NIFI-7873-RC4 prepare for next development iteration
|
2021-02-15 12:09:31 -07:00 |
|
Joe Witt
|
487280bee9
|
NIFI-7873-RC4 prepare release nifi-1.13.0-RC4
|
2021-02-15 12:09:30 -07:00 |
|
Mark Payne
|
783633cac5
|
NIFI-8021: Fixed bug in ConsumeKafka_2_6 and ConsumeKafkaRecord_2_6 where explicit partition assignment causes issues with more than 1 concurrent task. Also fixed bug that prevented more nifi nodes than partitions because it didn't properly handle empty string for the list of partitions
Signed-off-by: Pierre Villard <pierre.villard.fr@gmail.com>
This closes #4744.
|
2021-01-06 19:28:09 +01:00 |
|
Peter Turcsanyi
|
91f6b42985
|
NIFI-8085 Use poll(Duration) in ConsumeKafka_2_x processors
Signed-off-by: Pierre Villard <pierre.villard.fr@gmail.com>
This closes #4725.
|
2020-12-13 10:23:35 +01:00 |
|
Mark Payne
|
7848ba59a2
|
NIFI-8021: Provide the ability to pin partitions to particular hosts when using ConsumeKafka processors
Signed-off-by: Pierre Villard <pierre.villard.fr@gmail.com>
This closes #4672.
|
2020-11-18 16:03:24 +01:00 |
|
Mark Payne
|
c610aab3cb
|
NIFI-7953: Updated ConsumeKafka_2_0/ConsumeKafkaRecord_2_0/ConsumeKafka_2_6/ConsumeKafkaRecord_2_6 to allow separating records by key
|
2020-10-27 19:04:19 -04:00 |
|
Joe Witt
|
8baa5c9940
|
NIFI-7692 updating for next dev release 1.13.0
|
2020-08-18 14:48:02 -07:00 |
|
Joe Witt
|
fb57bcbc11
|
NIFI-7692-RC1 prepare for next development iteration
|
2020-08-13 09:20:39 -07:00 |
|
Joe Witt
|
303d6c59ba
|
NIFI-7692-RC1 prepare release nifi-1.12.0-RC1
|
2020-08-13 09:20:36 -07:00 |
|
Joe Witt
|
58e324e9f1
|
NIFI-7522 bumping from Apache Kafka 2.5 to Apache Kafka 2.6
Signed-off-by: Pierre Villard <pierre.villard.fr@gmail.com>
This closes #4462.
|
2020-08-10 09:55:53 +02:00 |
|