[
https://issues.apache.org/jira/browse/NIFI-13928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17945292#comment-17945292
]
Pierre Villard commented on NIFI-13928:
---------------------------------------
Yes [~pgrey] - totally agree
> adjust default PartitioningStrategy option in processor PublishKafka
> ---------------------------------------------------------------------
>
> Key: NIFI-13928
> URL: https://issues.apache.org/jira/browse/NIFI-13928
> Project: Apache NiFi
> Issue Type: Improvement
> Reporter: Paul Grey
> Priority: Minor
>
> Apache Kafka 3.3.0 altered the available partitioner strategies [1],
> deprecating the default partitioner [2]. This causes a warning line [3] to
> be emitted by the NiFi logging subsystem on Kafka writes, when the default
> NiFi processor partitioning strategy is used.
> Consider adjustments to the available component configuration options to
> align with present client library behavior.
> [1]
> https://www.confluent.io/blog/apache-kafka-3-3-0-new-features-and-updates/#strictly-uniform-sticky-partitioner
> [2]
> https://github.com/a0x8o/kafka/blob/54eff6af115ee647f60129f2ce6a044cb17215d0/clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java#L325-L329
> [3]
> WARN [Timer-Driven Process Thread-10]
> o.a.kafka.clients.producer.KafkaProducer [Producer
> clientId=producer-ecee1d42-9b3b-474b-a85b-440977e62f0c,
> transactionalId=ecee1d42-9b3b-474b-a85b-440977e62f0c] DefaultPartitioner is
> deprecated. Please clear partitioner.class configuration setting to get the
> default partitioning behavior
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
