[ https://issues.apache.org/jira/browse/KAFKA-5059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15967233#comment-15967233 ]
ASF GitHub Bot commented on KAFKA-5059: --------------------------------------- GitHub user dguy opened a pull request: https://github.com/apache/kafka/pull/2849 KAFKA-5059: Implement Transactional Coordinator You can merge this pull request into a Git repository by running: $ git pull https://github.com/confluentinc/kafka exactly-once-tc Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/2849.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #2849 ---- commit 4d17b7c96293ca8f9735049070512be9707aba27 Author: Guozhang Wang <wangg...@gmail.com> Date: 2017-03-02T01:42:49Z Transaction log message format (#134) * add transaction log message format * add transaction timeout to initPid request * collapse to one message type commit af926510d2fd455a0ea4e82da83e10cde65db4e9 Author: Apurva Mehta <apu...@confluent.io> Date: 2017-03-15T20:47:25Z Fix build and test errors due to reabse onto idempotent-producer branch commit fc3544bf6b55c48d487ef2b7877280d3ac90debb Author: Guozhang Wang <wangg...@gmail.com> Date: 2017-03-17T05:40:49Z Transaction log partition Immigration and Emigration (#142) * sub-package transaction and group classes within coordinator * add loading and cleaning up logic * add transaction configs commit fc5fe9226dd4374018f6b5fe3c182158530af193 Author: Guozhang Wang <wangg...@gmail.com> Date: 2017-03-21T04:38:35Z Add transactions broker configs (#146) * add all broker-side configs * check for transaction timeout value * added one more exception type commit ef390df0eacc8d1f32f96b2db792326a053a5db1 Author: Guozhang Wang <wangg...@gmail.com> Date: 2017-03-31T22:20:05Z Handle addPartitions and addOffsets on TC (#147) * handling add offsets to txn * add a pending state with prepareTransition / completeTransaction / abortTransition of state * refactor handling logic for multiple in-flight requests commit 2a6526a861546eb4102b900d1da703fd2914bd43 Author: Apurva Mehta <apu...@confluent.io> Date: 2017-04-07T19:49:19Z Fix build errors after rebase onto trunk and dropping out the request stubs and client changes. commit 4d18bb178cd48364bf610e615b176ad8f0d8385f Author: Apurva Mehta <apu...@confluent.io> Date: 2017-04-03T21:17:25Z Fix test errors after rebase: 1. Notable conflicts are with the small API changes to DelayedOperation and the newly introduced purgeDataBefore PR. 2. Jason's update to support streaming decompression required a bit of an overhaul to the way we handle aborted transactions on the consumer. commit f639b962e8ba618baaef47611e21e2b85b5e5725 Author: Guozhang Wang <wangg...@gmail.com> Date: 2017-03-24T22:42:53Z fix unit tests commit 853c5e8abffdb723c6f6b818fdeeab94da8667ed Author: Guozhang Wang <wangg...@gmail.com> Date: 2017-03-24T22:52:37Z add sender thread commit 879c01c3b5b305485cfd26cb8ceedf453b984067 Author: Guozhang Wang <wangg...@gmail.com> Date: 2017-03-28T01:04:53Z rename TC Send Thread to general inter-broker send thread commit 239e7f733f8b814ca2d966a80359d8d0de5dee50 Author: Guozhang Wang <wangg...@gmail.com> Date: 2017-03-29T21:58:45Z add tc channel manager commit b1561da6e2893fad7bcfacba76db4e4df6414577 Author: Guozhang Wang <wangg...@gmail.com> Date: 2017-03-29T21:59:26Z missing files commit 62685c7269fc648a2401fc7a71f31b9536d7c08a Author: Guozhang Wang <wangg...@gmail.com> Date: 2017-03-31T22:15:37Z add the txn marker channel manager commit 298790154c9bfe46f8e4a6b2e0372297fb19896a Author: Damian Guy <damian....@gmail.com> Date: 2017-04-05T16:09:27Z fix compilation errors commit 4f5c23d051453d27f3179a442fe3d822b77d4e12 Author: Damian Guy <damian....@gmail.com> Date: 2017-04-10T10:58:43Z integrate EndTxnRequest commit e5f25f31e85fd8104c3df8f8195ccb60694610bc Author: Damian Guy <damian....@gmail.com> Date: 2017-04-10T13:43:40Z add test fo InterBrokerSendThread. Refactor to use delegation rather than inheritance commit 8bbd7a07be28585cd329a1fc769fcc340f866af2 Author: Damian Guy <damian....@gmail.com> Date: 2017-04-10T16:24:24Z refactor TransactionMarkerChannelManager. Add some test commit 195bccf8c3945696e6e15cc093072ba83e706eec Author: Damian Guy <damian....@gmail.com> Date: 2017-04-10T18:25:57Z more tests commit c28eb5a0b339cce023e278d7eafcf3e8a98fa8e2 Author: Damian Guy <damian....@gmail.com> Date: 2017-04-11T09:23:36Z remove some answered TODOs commit 4346c4d36f242e2480e4a808bed0ef19df6a2335 Author: Damian Guy <damian....@gmail.com> Date: 2017-04-11T15:46:37Z update to WriteTxnMarkersRequest/Response from Trunk commit 46880d78eae7d2e7853c404bd1d9b19b8ec4e569 Author: Damian Guy <damian....@gmail.com> Date: 2017-04-11T16:19:01Z add missing @Test annotation commit cbcd55e0d046d8c6d88ddfa5bbdfbc230b171e13 Author: Damian Guy <damian....@gmail.com> Date: 2017-04-12T19:59:19Z fixes after rebase Add tests for TransactionMarkerRequestCompletionHandler commit b307e5d395afb4fafaa4546d1284b9e5bc73c146 Author: Damian Guy <damian....@gmail.com> Date: 2017-04-13T07:25:35Z Merge pull request #161 from confluentinc/exactly-once-end-txn Exactly once end txn ---- > Implement Transactional Coordinator > ----------------------------------- > > Key: KAFKA-5059 > URL: https://issues.apache.org/jira/browse/KAFKA-5059 > Project: Kafka > Issue Type: New Feature > Components: core > Reporter: Damian Guy > Assignee: Damian Guy > > This covers the implementation of the transaction coordinator to support > transactions, as described in KIP-98: > https://cwiki.apache.org/confluence/display/KAFKA/KIP-98+-+Exactly+Once+Delivery+and+Transactional+Messaging -- This message was sent by Atlassian JIRA (v6.3.15#6346)