philipnee commented on PR #15000: URL: https://github.com/apache/kafka/pull/15000#issuecomment-1887951845
hey @lucasbru - i assume invoker queue here you meant by `OffsetCommitCallbackInvoker`. It is not shared with the background thread. There are two invokers used by the async consumer, one is the offset commit callback invoker, the other one is the rebalance callback. The rebalance callback is shared by the two threads but the commit callback invoker is not. my original thought was to use the background event to pass the interceptor onCommit event. i think we are all on the same page about using the invoker to invoke the events. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
