- Propagate kafka record timestamps for source detection latency
- New configuration option
rockset.retry.backoff.ms
- Removed deprecated configurations
rockset.apikey
,rockset.collection
, androckset.workspace
- Bug fix for potential out-of-order message delivery
- Update rockset-java client dependency
- Update dependencies to latest
- Fix Avro parser handling nulls
- Fix timestamp handling
- Add batch size parameter
- Support list type messages
- Don't throw errors from put. Only flush call handles failures.
- Do not block all threads during retries.
- Connector now supports keys in messages for all types
_id
for documents are now assigned on the server side. This could cause collections to have duplicate docs for a message- Key for a message is now part of the document, under
_meta.kafka.key
- use new Rockset API Receiver Endpoint to send documents
- Retry on different 5xx errors and Socket Timeout
- Limit batch size to 1000 documents
- use blocking executor to prevent overloading the thread pool
- Handle failures and report it to Kafka for retries
- Initial Kafka Connect for Rockset release
- Support for Avro format
- Better logging and error messages
- Documentation of options
- Graceful retries, exactly once delivery
- Unit tests and performance testing