You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@nifi.apache.org by "Firenz (Jira)" <ji...@apache.org> on 2020/06/11 07:45:00 UTC

[jira] [Created] (NIFI-7522) Processor Kafka 2.5 / Static Membership

Firenz created NIFI-7522:
----------------------------

             Summary: Processor Kafka 2.5 / Static Membership
                 Key: NIFI-7522
                 URL: https://issues.apache.org/jira/browse/NIFI-7522
             Project: Apache NiFi
          Issue Type: Improvement
          Components: Extensions
            Reporter: Firenz
         Attachments: nifi-kafka-2-5-nar-1.11.5-SNAPSHOT.nar

Kafka 2.4 introduced the static membership [[KIP-345|https://cwiki.apache.org/confluence/display/KAFKA/KIP-345%3A+Introduce+static+membership+protocol+to+reduce+consumer+rebalances]|[https://cwiki.apache.org/confluence/display/KAFKA/KIP-345%3A+Introduce+static+membership+protocol+to+reduce+consumer+rebalances]]

 

So i propose to add a Publish/Consume 2_5 with the last Kafka Client 2.5. 

 

I don't know the versionning strategy for Kafka Processors. There is no difference between the 2.0 and 2.5 processor (no new fields, the group.instance.id is added with dynamic properties).

 

So i created a new set of 2.5 processors from 1.11.5-SNAPSHOT. It builds, test ok. But i need to learn the full process to create the branch/pull/merge request etc. For people in the urge or just curious, my last build is attached.

 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)