GitHub user sborya opened a pull request:
https://github.com/apache/samza/pull/624
New consumer for kafka system
Remove SimpleConsumer and BrokerProxy from Samza's KafkaSystemConsumer
implementation.
Instead use KafkaConsumerProxy with high-level kafka consumer.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/sborya/samza NewConsumer2
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/samza/pull/624.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 #624
----
commit a31a7aa29b7be4bb46f8e651b6b8fa46a65b48e2
Author: Boris Shkolnik <bshkolni@...>
Date: 2017-10-16T22:25:49Z
reduce debugging from info to debug in KafkaCheckpointManager.java
commit 410ce78ba1ff8dafa2587481473e62ac9cfa6f4f
Author: Boris S <boryas@...>
Date: 2017-10-17T01:20:04Z
Merge branch 'master' of https://github.com/apache/samza
commit d4620d6690f74cad9472d0e27a1b31aeb4156c54
Author: Boris S <boryas@...>
Date: 2017-10-25T00:11:48Z
Merge branch 'master' of https://github.com/apache/samza
commit bbffb79b8b9799a41e8e82ded60f83550736886b
Author: Boris S <boryas@...>
Date: 2017-10-25T00:54:20Z
Merge branch 'master' of https://github.com/apache/samza
commit 010fa168ee2a290b93f5a3b0908709b2c19044ec
Author: Boris S <boryas@...>
Date: 2017-10-25T01:33:03Z
Merge branch 'master' of https://github.com/apache/samza
commit 5e6f5fb5f9a9ee12ce35ee8eb1836a058521df20
Author: Boris Shkolnik <bshkolni@...>
Date: 2017-10-25T16:50:37Z
Merge branch 'master' of https://github.com/apache/samza
commit 06b1ac36e9c67a3bd558a0fa592639b16fcbfda9
Author: Boris Shkolnik <bshkolni@...>
Date: 2017-10-25T16:50:55Z
Merge branch 'master' of https://github.com/sborya/samza
commit 1ad58d43fbe00a57054cb85b0be2eef6ee6470a6
Author: Boris S <boryas@...>
Date: 2017-10-31T19:46:53Z
Merge branch 'master' of https://github.com/apache/samza
commit dd39d089437905abb93aa1074474b28a18292a54
Author: Boris S <boryas@...>
Date: 2017-11-22T19:46:37Z
Merge branch 'master' of https://github.com/apache/samza
commit 67e611ee47f0747b81c0de5d061f9888145b605a
Author: Boris S <boryas@...>
Date: 2018-01-10T17:50:40Z
Merge branch 'master' of https://github.com/apache/samza
commit 0edf343b8c5360437fa10cc5a543696a4edcc319
Author: Boris S <boryas@...>
Date: 2018-06-08T17:15:36Z
Merge branch 'master' of https://github.com/apache/samza
commit 88f855954e4d98aa3bdd3a3a778eb699a13ff659
Author: Boris S <boryas@...>
Date: 2018-08-02T20:29:58Z
Merge branch 'master' of https://github.com/apache/samza
commit 78ad578cc022af3f9c5f9a15826a9dc010502a89
Author: Boris S <boryas@...>
Date: 2018-08-08T02:04:17Z
Merge branch 'master' of https://github.com/apache/samza
commit 7887d884e8a062563a7e4b8b418d817828f51f23
Author: Boris S <boryas@...>
Date: 2018-08-13T06:48:39Z
Merge branch 'master' of https://github.com/apache/samza
commit afb34d916b435c1c08fe80009cc7d47d8287e27f
Author: Boris S <boryas@...>
Date: 2018-08-13T06:48:54Z
Merge branch 'master' of https://github.com/sborya/samza
commit 57fca52cc48a37622aa6b8b1f71a37733c378524
Author: Boris S <boryas@...>
Date: 2018-08-15T19:13:37Z
Merge branch 'master' of https://github.com/apache/samza
commit 4801709f3d8d2b50a059abb830de23ffcdaffda5
Author: Boris S <boryas@...>
Date: 2018-08-16T17:38:26Z
test
commit 72544606bfffc67aeaa7f509ca54cfd6db52e2b4
Author: Boris S <boryas@...>
Date: 2018-08-18T01:08:52Z
Added new KafkaProxy and KafkaConsumer for default KafkaSystem
commit 7f7b5594c21e9e3ebf25d243cbf078dbf6201a0f
Author: Boris S <boryas@...>
Date: 2018-08-22T18:31:26Z
Merge branch 'master' of https://github.com/apache/samza
commit c0ea25cbc674a1d67546f7f47a6f36f6ee58bdc6
Author: Boris S <boryas@...>
Date: 2018-08-29T17:52:30Z
added new samza kafka system consumer using new kafka consumer
commit 34ae8ba2dd18c7d7af46464033b330a35966db3f
Author: Boris S <boryas@...>
Date: 2018-08-29T17:52:37Z
Merge branch 'master' into NewConsumer
commit 89f79829107ed21dd88058922b6038835af1cfbd
Author: Boris S <boryas@...>
Date: 2018-08-30T17:30:55Z
added test
commit 8ab04b209eec4d035f126259305ae84318737d2e
Author: Boris S <boryas@...>
Date: 2018-08-30T18:43:21Z
Merge branch 'master' of https://github.com/apache/samza
commit c14557fb401f0d718e78163a159695f50bc82845
Author: Boris S <boryas@...>
Date: 2018-08-30T19:45:23Z
Merge branch 'master' into NewConsumer
commit 22034947b998d3604bc3911a417b9c1e761bb90f
Author: Boris S <boryas@...>
Date: 2018-08-31T21:36:51Z
added JobModelManager to ThreadJob
commit 59b3dc1c2c1820c899b5d5b217b0268d119348af
Author: Boris S <boryas@...>
Date: 2018-08-31T22:11:39Z
added apache license
commit 19ba3003078f989400cd9fbefee7c00421bebc6c
Author: Boris S <boryas@...>
Date: 2018-08-31T22:15:04Z
LOG line
commit b5ce9b38da88318a625f1dd7a6d35b9ed14ca04b
Author: Boris S <boryas@...>
Date: 2018-09-05T00:22:16Z
added eventPrcoessed sync
commit add733b85f78046badd9af36ebf533d19388151c
Author: Boris S <boryas@...>
Date: 2018-09-05T00:23:06Z
Merge branch 'master' of https://github.com/apache/samza
commit bab5bdd5a8d12ae0efcd6d3b5c5601d476470373
Author: Boris S <boryas@...>
Date: 2018-09-05T00:23:51Z
Merge branch 'master' into NewConsumer
----
---
