Description
I tried to consume a Kafka topic to a table with a jsonSpec extracting a single column from the key and a simpleSpec to get the value as another column.
It resulted in an error like:
Chunk sizes don't match: 500, 500, 500, 1000, 0
Debugging, it looks like 500 records are processed and the 3 automatically added Kafka columns have a matching chunk size, but my key column has 1000 and the value column 0?
If I change the key spec to a simpleSpec it works.
Versions
Description
I tried to consume a Kafka topic to a table with a jsonSpec extracting a single column from the key and a simpleSpec to get the value as another column.
It resulted in an error like:
Chunk sizes don't match: 500, 500, 500, 1000, 0
Debugging, it looks like 500 records are processed and the 3 automatically added Kafka columns have a matching chunk size, but my key column has 1000 and the value column 0?
If I change the key spec to a simpleSpec it works.
Versions