[jira] [Commented] (KAFKA-1523) Implement transaction manager module
[ https://issues.apache.org/jira/browse/KAFKA-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=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)
[jira] [Commented] (KAFKA-1523) Implement transaction manager module
[ https://issues.apache.org/jira/browse/KAFKA-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14071130#comment-14071130 ] 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 * 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)
[jira] [Commented] (KAFKA-1523) Implement transaction manager module
[ https://issues.apache.org/jira/browse/KAFKA-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14065912#comment-14065912 ] 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.patch, KAFKA-1523_2014-07-17_19:26:34.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)
[jira] [Commented] (KAFKA-1523) Implement transaction manager module
[ https://issues.apache.org/jira/browse/KAFKA-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14065952#comment-14065952 ] Dong Lin commented on KAFKA-1523: - python kafka-patch-review.py incorrectly involves needed changes... Need to do it again. 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.patch, KAFKA-1523_2014-07-17_20:01:21.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)
[jira] [Commented] (KAFKA-1523) Implement transaction manager module
[ https://issues.apache.org/jira/browse/KAFKA-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14065948#comment-14065948 ] 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.patch, KAFKA-1523_2014-07-17_20:01:21.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)
[jira] [Commented] (KAFKA-1523) Implement transaction manager module
[ https://issues.apache.org/jira/browse/KAFKA-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14065963#comment-14065963 ] 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 * 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)
[jira] [Commented] (KAFKA-1523) Implement transaction manager module
[ https://issues.apache.org/jira/browse/KAFKA-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14064128#comment-14064128 ] Dong Lin commented on KAFKA-1523: - Created 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.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)
