Nicholas Sun
Nicholas Sun
Hi @arianitu , have you had a chance to try the Writer in "asynchronous mode"? Docs: https://pkg.go.dev/github.com/segmentio/kafka-go#Writer Code: https://github.com/segmentio/kafka-go/blob/b952e635d4f1b688854c1097cd7ce6eeaf50b273/writer.go#L54-L74
Hi, thanks for all the ideas, we probably won't change the API of `WriteMessages` but going by the comments it could be worth looking into creating a new function that:...
@yusufozturk thanks for the PR. Just to clarify since I ended up forgetting the original purpose of this issue: The original ask was something along the lines of > Add...
Hi there, I'm probably missing some context but is there a reason you want to avoid reading from a consumer group?
One option is to pin a consumer group to each instance and reset the offset of the consumer group upon startup of the instance. Although this has other complications like...
Yup speaking about the feature not Segment, we don't have much insight into this use case, if it turns out to be a common use case we could consider merging...
@fvosberg Hi there, any updates on this?
Hi @rockxsj @calvinbrown085 , I was thinking about this more, but is there a reason a consumer group is not sufficient for this use case? It appears to me that...
hi @alrz1999, any updates here?
@nmerkulov go for it!