[KAFKA-7015] Enhance RecordCollectorImpl exceptions with more context information

• Type: Improvement
• Status: Resolved
• Priority: Minor
• Resolution: Not A Problem
• Affects Version/s: 1.1.0
• Component/s: streams
• Assignee: Unassigned
• Reporter: Matthias J. Sax
• Created: 07/Jun/18 03:50
• Updated: 15/May/20 02:47
• Resolved: 15/May/20 02:47

Description

In KIP-182 we refactored all stores to by plain Bytes/byte[] stores and only have concrete key/value types on outer layers/wrappers of the stores.

For this reason, the most inner RocksDBStore cannot provide useful error messages anymore if a put/get/delete operation fails as it only handles plain bytes.

In addition, the corresponding calls to record changelog records to record collectors will also be sending byte arrays only, and hence when there is an error happening, the record collector can only display the key but not the value since it is all bytes:

[ERROR] org.apache.kafka.streams.processor.internals.RecordCollectorImpl   -
task [2_2] Error sending record (key {"eventId":XXX,"version":123}
value [<byte array>] timestamp YYY) to topic TTT
due to ...

The store exceptions got fixed via KAFKA-6538.

This Jira is to track the fix for RecordCollectorImpl.

Issue Links

• is related to: KAFKA-6538 Enhance ByteStore exceptions with more context information
• links to: GitHub Pull Request #5224