- Nothing changed yet.
- Handle retryQ and DLQ only consumer topics.
- Update KafkaPartitionOwned metric to be a boolean metric for ownership.
- Rename number of partitions owned by specific worker to KafkaPartitionOwnedCount.
- Add client id option.
- Add method to nack to DLQ.
- Tune producer max message bytes to 10mb.
- Tune consumer default fetch bytes to 10mb.
- Remove Offset.Initial.Reset config since it is unused.
- Add Offset.Commit.Enabled config to enable auto offset commit.
- Tune partition consumer logs to debug level
- Remove Topic.BrokerList since it was unused in favor of NameResolver to resolve broker list.
- Change sarama log to warn level.
- Add metric for freshness
- Allow RetryCount = -1 to signal infinite retry.
- Fix off by one error for offset-lag metric.
- Fix reset of rangePartitionConsumer with existing reset does not trigger new merge.
- Update sarama config version to use 0.10.2.
- Fix DLQMetadata decoding to use DLQMetadataDecoder func instead of inferred decoding from TopicType.
- Fix consumer to use noopDLQ if RetryQ or DLQ in config is empty.
- Fix ResetOffset fails on partition rebalance.
- Add delay to Topic configuration
- Add WithRetryTopics and WithDLQTopics to inject additional consumers for additional retry or DLQ topics.
- Pin sarama-cluster to 2.1.13.
- Fixed sarama-cluster dependency pin to cf455bc755fe41ac9bb2861e7a961833d9c2ecc3 because we need ResetOffsets method with NPE fix.
- Added initial release