Major Description
Kafka Connect's JSON Converter will never output a null value when enableSchemas=true. This means that when a connector outputs a SourceRecord with a null value, the JSON Converter will always produce a message value with:
{
"schema": null,
"payload": null
}
And, this means that while Kafka log compaction will always be able to remove earlier messages with the same key, log compaction will never remove all of the messages with the same key.
The JSON Connector's fromConnectData(...) should always return null when it is supplied a null value.
Attachments
Issue Links
- links to