Paul Grey created NIFI-13928:
--------------------------------
Summary: 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
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)
