[GitHub] kafka pull request #4106: Kafka 5849

[cmccabe <gi...@git.apache.org>]

GitHub user cmccabe opened a pull request:

    https://github.com/apache/kafka/pull/4106

    Kafka 5849

    

You can merge this pull request into a Git repository by running:

    $ git pull https://github.com/cmccabe/kafka KAFKA-5849

Alternatively you can review and apply these changes as the patch at:

    https://github.com/apache/kafka/pull/4106.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 #4106
    
----
commit 55eaf4274dfd2a3dd7782017455cb2cb2a9f5e1e
Author: Colin P. Mccabe <cm...@confluent.io>
Date:   2017-09-26T01:30:13Z

    KAFKA-6060: Add workload generation capabilities to Trogdor
    
    Previously, Trogdor only handled "Faults."  Now, Trogdor can handle
    "Tasks" which may be either faults, or workloads to execute in the
    background.
    
    The Agent and Coordinator have been refactored from a
    mutexes-and-condition-variables paradigm into a message passing
    paradigm.  No locks are necessary, because only one thread can access
    the task state or worker state.  This makes them a lot easier to reason
    about.
    
    The MockTime class can now handle mocking deferred message passing
    (adding a message to an ExecutorService with a delay).  I added a
    MockTimeTest.
    
    MiniTrogdorCluster now starts up Agent and Coordinator classes in
    paralle in order to minimize junit test time.
    
    RPC messages now inherit from a common Message.java class.  This class
    handles implementing serialization, equals, hashCode, etc.
    
    Remove FaultSet, since it is no longer necessary.
    
    Previously, if CoordinatorClient or AgentClient hit a networking
    problem, they would throw an exception.  They now retry several times
    before giving up.  Additionally, the REST RPCs to the Coordinator and
    Agent have been changed to be idempotent.  If a response is lost, and
    the request is resent, no harm will be done.

commit 1484ea020c66dd0c7368d9ec7ba0616710f22ca1
Author: Colin P. Mccabe <cm...@confluent.io>
Date:   2017-10-20T20:25:08Z

    KAFKA-5849: Add partitioned produce consume test

----


---

[GitHub] kafka pull request #4106: KAFKA-5849: Add partitioned produce consume test

[cmccabe <gi...@git.apache.org>]

Github user cmccabe closed the pull request at:

    https://github.com/apache/kafka/pull/4106


---