[KAFKA-10457] JsonConverter.toConnectData trims BigInteger to Long for schema-less case

• Type: Bug
• Status: In Progress
• Priority: Critical
• Resolution: Unresolved
• Component/s: connect
• Assignee: Sudesh Wasnik
• Reporter: Oleksandr Diachenko
• Created: 02/Sep/20 04:39
• Updated: 10/Dec/23 18:17

Description

 

When JsonConverter is configured with schemas.enable=false and value, exceeding Double is passed, the result is incorrect since the converter trims it to Double:

Map<String, Boolean> props = Collections.singletonMap("schemas.enable", false);
converter.configure(props, true);
BigInteger value = BigInteger.valueOf(Long.MAX_VALUE).add(new BigInteger("1"));
String msg = value.toString();
SchemaAndValue schemaAndValue = converter.toConnectData(TOPIC, msg.getBytes());
assertNull(schemaAndValue.schema());
assertEquals(value, schemaAndValue.value());

 

 Fails with:

 

expected:<9223372036854775808> but was:<-9223372036854775808>
Expected :9223372036854775808
Actual :-9223372036854775808