[
https://issues.apache.org/jira/browse/KAFKA-20000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18050745#comment-18050745
]
Francis Godinho commented on KAFKA-20000:
-----------------------------------------
[~chickenchickenlove], thanks again for your suggestion! ive been trying to
understand the code and i see that
[GroupCoordinatorService.commitTransactionalOffsets|[https://github.com/apache/kafka/blob/trunk/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java#L2075]]
eventually calls runtime.scheduleTransactionalWriteOperation() (from what I
understand, this writes to local disk and doesn't make any RPC calls). I don't
see other methods that actually sends requests to the Transaction Coordinator.
Are you able to help point me to the code/function in Group Coordinator that
actually sends the offsets?
> Optimize retry backoff for CONCURRENT_TRANSACTIONS to improve TV2 throughput
> ----------------------------------------------------------------------------
>
> Key: KAFKA-20000
> URL: https://issues.apache.org/jira/browse/KAFKA-20000
> Project: Kafka
> Issue Type: Improvement
> Reporter: Chia-Ping Tsai
> Assignee: Francis Godinho
> Priority: Major
> Fix For: 4.3.0
>
>
> Transaction V2 introduces frequent state transitions (epoch bumps) that
> briefly reject concurrent requests with CONCURRENT_TRANSACTIONS. The default
> client retry backoff (100ms) is excessive for these transient locks, leading
> to unnecessary latency and degraded throughput. Reducing the backoff allows
> faster retries and smoother performance during state transitions.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
