Interesting.
The largest number representable by a 32 bit integer is 2147483647.
Which exactly one less than th number you have.
That sounds like a hint...
Sent via the Samsung Galaxy A54 5G, an AT&T 5G smartphone
-------- Original message --------
From: "Richter, Robert" <robert.rich...@sva.de>
Date: 7/11/24 5:38 AM (GMT-05:00)
To: users@nifi.apache.org
Subject: PublishKafkaRecord_2_6 produces negative partition number
Hello NiFi Community,
we’ve encountered an error in one of our pipelines. Exactly one record cannot
be processed by the PublishKafkaRecord_2_6 processor. The Processor throws the
following exception.
java.lang.IllegalArgumentException: Invalid partition: -8. Partition number
should always be non-negative or null.
The processor is configured as follows and we’re on NiFi version 1.23.2. The
topic we’re publishing on has 20 partitions:
* partitioner class: record path partitioner
* partition: /NumericId
* Message Key Field: NumericId
The processor fails only for records with value 2147483648 in the message key
field. All other records can be processed without failure. (millions per day)
We tried different reader and writer. Avro with and without schema registry and
plain json. The result is the same.
Here’s an example record.
[ {
"_loadstamp" : "20240711075814350",
"Id" : "04948E4E-94B1-84HD-94CA-AB84020F729",
"NumericId" : 2147483648,
"TimeStamp" : "2024-06-12 15:30:58.341 +02:00",
"SequenceNumber" : 123456789,
"IsTrendUploaded" : false,
"CompoundValueId" : null,
"Value" : 1.0,
"Score" : 65535,
"ScoreColor" : 0,
"CompositeId" : null
} ]
Kind regard
Robert
Das SVA Mail-System ist mit einem Mailverschluesselungs-Gateway ausgestattet.
Wenn Sie moechten, dass an Sie gerichtete E-Mails verschluesselt werden, senden
Sie einfach eine S/MIME-signierte E-Mail oder Ihren PGP Public Key an
robert.rich...@sva.de.
The SVA mail system is equipped with an email encryption gateway. If you want
email sent to you to be encrypted please send a S/MIME signed email or your PGP
public key to robert.rich...@sva.de.
