You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Dong Lin (JIRA)" <ji...@apache.org> on 2014/08/06 06:28:12 UTC

[jira] [Commented] (KAFKA-1523) Implement transaction manager module

    [ https://issues.apache.org/jira/browse/KAFKA-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14087228#comment-14087228 ] 

Dong Lin commented on KAFKA-1523:
---------------------------------

Updated reviewboard https://reviews.apache.org/r/23568/diff/
 against branch origin/transactional_messaging

> Implement transaction manager module
> ------------------------------------
>
>                 Key: KAFKA-1523
>                 URL: https://issues.apache.org/jira/browse/KAFKA-1523
>             Project: Kafka
>          Issue Type: New Feature
>            Reporter: Joel Koshy
>            Assignee: Dong Lin
>              Labels: transactions
>         Attachments: KAFKA-1523_2014-07-17_20:12:55.patch, KAFKA-1523_2014-07-22_16:45:42.patch, KAFKA-1523_2014-08-05_21:25:55.patch
>
>
> * Entry point for transaction requests
> * Appends transaction control records to the transaction journal
> * Sends transaction control records to data brokers
> * Responsible for expiring transactions
> * Supports fail-over: for which it needs to maintain a transaction HW which is the offset of the BEGIN control record of the earliest pending transaction. It should checkpoint the HW periodically either to ZK/separate topic/offset commit.
> The scope of this ticket will be the basic transaction coordinator functionality. E.g., we can just have a basic transaction manager that can begin/commit/abort transactions. No expiration, no fail-over. We will add failure handling in subsequent jiras.



--
This message was sent by Atlassian JIRA
(v6.2#6252)