3.0.0
This is a major release and contains a number of breaking changes. Please see the upgrade guide for more information on how to upgrade from version 2.x.
Closed issues:
- Support multiple
SinkTask
instances #138 - Remove orphaned config #135
- Support
Struct
fields in chanel and message name mapping #134 - Configurable buffering of incoming records #133
- Submit records using Batch API #124
- Test on MSK #123
- Offset tracking and committing #121
- Integration Testing #120
- DLQ Error Handling #119
Merged pull requests:
- docs: readme entry for Confluent Cloud BYOC #147 (AndyTWF)
- v3.0.0 #146 (AndyTWF)
- Documentation and Config updates #142 (jaley)
- Structured field access for channel and message name mappings #141 (jaley)
- Support multiple tasks #140 (jaley)
- Remove legacy config and documentation #139 (jaley)
- Restore integration tests and fix related bugs #137 (jaley)
- Buffer incoming
SinkRecords
before sending batches #132 (jaley) - End to end testing #131 (jaley)
- Added OffsetRegistryService class to store offsets by kafka topic/par… #130 (subkanthi)
- MSK Packaging & Example Deployment #129 (jaley)
- Kafka DLQ #128 (subkanthi)
- Update to Confluent Platform 7.4.0 #127 (jaley)
- Fix Docker build errors #126 (jaley)
- Batch API changes, create Threadpoolexecutor, add logic to batch mess… #125 (subkanthi)