[
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 <[email protected]>
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 <[email protected]>
Date: 2017-03-15T20:47:25Z
Fix build and test errors due to reabse onto idempotent-producer branch
commit fc3544bf6b55c48d487ef2b7877280d3ac90debb
Author: Guozhang Wang <[email protected]>
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 <[email protected]>
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 <[email protected]>
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 <[email protected]>
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 <[email protected]>
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 <[email protected]>
Date: 2017-03-24T22:42:53Z
fix unit tests
commit 853c5e8abffdb723c6f6b818fdeeab94da8667ed
Author: Guozhang Wang <[email protected]>
Date: 2017-03-24T22:52:37Z
add sender thread
commit 879c01c3b5b305485cfd26cb8ceedf453b984067
Author: Guozhang Wang <[email protected]>
Date: 2017-03-28T01:04:53Z
rename TC Send Thread to general inter-broker send thread
commit 239e7f733f8b814ca2d966a80359d8d0de5dee50
Author: Guozhang Wang <[email protected]>
Date: 2017-03-29T21:58:45Z
add tc channel manager
commit b1561da6e2893fad7bcfacba76db4e4df6414577
Author: Guozhang Wang <[email protected]>
Date: 2017-03-29T21:59:26Z
missing files
commit 62685c7269fc648a2401fc7a71f31b9536d7c08a
Author: Guozhang Wang <[email protected]>
Date: 2017-03-31T22:15:37Z
add the txn marker channel manager
commit 298790154c9bfe46f8e4a6b2e0372297fb19896a
Author: Damian Guy <[email protected]>
Date: 2017-04-05T16:09:27Z
fix compilation errors
commit 4f5c23d051453d27f3179a442fe3d822b77d4e12
Author: Damian Guy <[email protected]>
Date: 2017-04-10T10:58:43Z
integrate EndTxnRequest
commit e5f25f31e85fd8104c3df8f8195ccb60694610bc
Author: Damian Guy <[email protected]>
Date: 2017-04-10T13:43:40Z
add test fo InterBrokerSendThread. Refactor to use delegation rather than
inheritance
commit 8bbd7a07be28585cd329a1fc769fcc340f866af2
Author: Damian Guy <[email protected]>
Date: 2017-04-10T16:24:24Z
refactor TransactionMarkerChannelManager. Add some test
commit 195bccf8c3945696e6e15cc093072ba83e706eec
Author: Damian Guy <[email protected]>
Date: 2017-04-10T18:25:57Z
more tests
commit c28eb5a0b339cce023e278d7eafcf3e8a98fa8e2
Author: Damian Guy <[email protected]>
Date: 2017-04-11T09:23:36Z
remove some answered TODOs
commit 4346c4d36f242e2480e4a808bed0ef19df6a2335
Author: Damian Guy <[email protected]>
Date: 2017-04-11T15:46:37Z
update to WriteTxnMarkersRequest/Response from Trunk
commit 46880d78eae7d2e7853c404bd1d9b19b8ec4e569
Author: Damian Guy <[email protected]>
Date: 2017-04-11T16:19:01Z
add missing @Test annotation
commit cbcd55e0d046d8c6d88ddfa5bbdfbc230b171e13
Author: Damian Guy <[email protected]>
Date: 2017-04-12T19:59:19Z
fixes after rebase
Add tests for TransactionMarkerRequestCompletionHandler
commit b307e5d395afb4fafaa4546d1284b9e5bc73c146
Author: Damian Guy <[email protected]>
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)
