chore: upgrade kafka-go version #93
Merged
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
Upgrade Kafka-go version for Kafka 4.0 compatibility.
Greptile Summary
This PR upgrades the
github.com/segmentio/kafka-godependency from version 0.4.47 to 0.4.48 to add Kafka 4.0 compatibility. The change consists of updating two files:The kafka-go library is a critical dependency for the
kqpackage in this codebase, which implements Kafka-based message queuing functionality. Thekq/queue.gofile specifically uses this library to provide a Kafka queue implementation through thekafkaQueuestruct that implements thequeue.MessageQueueinterface.This is a patch-level version bump (0.4.47 → 0.4.48) within the same minor version, which typically indicates bug fixes, performance improvements, and infrastructure updates without breaking API changes. The upgrade ensures that users of the go-queue framework can work with newer Kafka 4.0 deployments while benefiting from the latest bug fixes and improvements in the underlying Kafka client library.
Confidence score: 4/5