[ https://issues.apache.org/jira/browse/NIFI-7522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Joe Witt reopened NIFI-7522: ---------------------------- Assignee: Joe Witt (was: Bryan Bende) > 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 > Assignee: Joe Witt > Priority: Minor > Labels: kafka, processor > Fix For: 1.12.0 > > Time Spent: 1h 50m > Remaining Estimate: 0h > > 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 versioning strategy for Kafka Processors. We have 2 choices > : > * Thanks to dynamic properties, upgrading the 2.0 processors set with 2.5 > kafka libs (confusing but lazy update) > * Create a new 2.5 processors set > > I've created a PR with the second choice : A new 2.5 processors set. > -- This message was sent by Atlassian Jira (v8.3.4#803005)