This repository was archived by the owner on Mar 2, 2026. It is now read-only.
Repository navigation
Changes
- Upgrade to Kafka Connect 4.1.0 compatibility
- Updated commitRecord method signature to include RecordMetadata parameter
- Updated Kafka Connect API dependency from 3.4.1 to 4.1.0
- Updated Java version from 8 to 11
- Fix NullPointerException risk in commitRecord method
- Add null checks for sourceOffset() and receipt handle extraction
- Improved error logging with partition/offset information