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

----


---

Reply via email to