Travis Bischel
Travis Bischel
When handling OOOSN
And add any other needed types, from group-coordinator/src/main/resources/common/message
https://github.com/grafana/mimir/pull/8886#issuecomment-2265802337 @pracucci to reply to your latest message in the thread -- if we strengthen the caching within franz-go itself, then it addresses caching the metadata request you mention, """...
These two functions are basically required if you use the BlockRebalanceOnPoll function when initializing a GroupTransactSession, so, it seems worth it to promote these to direct APIs on GTS. Closes...
This can help reduce latency if you produce infrequently, but know you'll be producing shortly. Closes #807.
* switch to RequestCachedMetadata * ListOffsets local log start offset, remote list offsets (-3, -4, -5) * DescribeGroups: handle error message * FindCoordinator v6 -- SHARE(2) type; format groupId:topicId:partition *...
Kafka expires group offsets differently depending on which OffsetCommit request version is used. v0: zookeeper based, out of scope v1, with commit timestamp: commit timestamp + offset.retention.minutes v1, no commit...