Joel Koshy created KAFKA-1523: --------------------------------- Summary: 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
* 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)