Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Add protocol TxnOffsetCommit v0 #169

Closed
tulios opened this issue Oct 10, 2018 · 2 comments
Closed

Add protocol TxnOffsetCommit v0 #169

tulios opened this issue Oct 10, 2018 · 2 comments
Assignees

Comments

@tulios
Copy link
Owner

tulios commented Oct 10, 2018

The producer will send a TxnOffsetCommit to the consumer coordinator to persist the offsets in the __consumer-offsets topic. The consumer coordinator validates that the producer is allowed to make this request (and is not a zombie) by using the ID and producer epoch which are sent as part of this request.

The consumed offsets are not visible externally until the transaction is committed.

TxnOffsetCommit Request (Version: 0) => transactional_id group_id producer_id producer_epoch [topics] 
  transactional_id => STRING
  group_id => STRING
  producer_id => INT64
  producer_epoch => INT16
  topics => topic [partitions] 
    topic => STRING
    partitions => partition offset metadata 
      partition => INT32
      offset => INT64
      metadata => NULLABLE_STRING
TxnOffsetCommit Response (Version: 0) => throttle_time_ms [topics] 
  throttle_time_ms => INT32
  topics => topic [partitions] 
    topic => STRING
    partitions => partition error_code 
      partition => INT32
      error_code => INT16

https://kafka.apache.org/protocol.html#The_Messages_TxnOffsetCommit

@ianwsperber
Copy link
Contributor

Starting work

@ianwsperber ianwsperber self-assigned this Nov 5, 2018
ianwsperber added a commit that referenced this issue Nov 5, 2018
@tulios
Copy link
Owner Author

tulios commented Nov 5, 2018

Edit:
closed the issue

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

No branches or pull requests

2 participants