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
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---
