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 ---- ---