This is an automated email from the ASF dual-hosted git repository.
turcsanyi pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git.
from 057b4af NIFI-8296 - Use API to retrieve all subjects associated with
a schema id for Confluent Schema Registry v5.4.0+
new 2f08d1f NIFI-8357: Updated Kafka 2.0 processors to automatically
handle recreating Consumer Lease objects when an existing one is poisoned, even
if using statically assigned partitions
new 74ea384 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
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../processors/kafka/pubsub/ConsumerLease.java | 4 +
.../nifi/processors/kafka/pubsub/ConsumerPool.java | 124 ++++++++++++++-------
.../processors/kafka/pubsub/ConsumerPoolTest.java | 86 ++++++++++++++
.../processors/kafka/pubsub/ConsumerLease.java | 4 +
.../nifi/processors/kafka/pubsub/ConsumerPool.java | 124 ++++++++++++++-------
.../processors/kafka/pubsub/ConsumerPoolTest.java | 85 ++++++++++++++
6 files changed, 350 insertions(+), 77 deletions(-)
