kafka git commit: HOTFIX: fix group coordinator edge cases around metadata storage callback

Repository: kafka Updated Branches: refs/heads/trunk 34d997665 -> 83fb73460 HOTFIX: fix group coordinator edge cases around metadata storage callback Author: Jason Gustafson Reviewers: Guozhang Wang Closes #451 from hachikuji/hotfix-group-coordinator Project:

[10/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/f2031d40/copycat/json/src/main/java/org/apache/kafka/copycat/json/JsonConverter.java -- diff --git a/copycat/json/src/main/java/org/apache/kafka/copycat/json/JsonConverter.java

[09/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/f2031d40/copycat/runtime/src/main/java/org/apache/kafka/copycat/errors/AlreadyExistsException.java -- diff --git

[14/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/417e283d/connect/runtime/src/test/java/org/apache/kafka/connect/storage/KafkaOffsetBackingStoreTest.java -- diff --git

[22/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/f2031d40/connect/json/src/main/java/org/apache/kafka/connect/json/JsonConverter.java -- diff --git a/connect/json/src/main/java/org/apache/kafka/connect/json/JsonConverter.java

[18/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/417e283d/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/CreateConnectorRequest.java -- diff --git

[11/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/417e283d/copycat/api/src/test/java/org/apache/kafka/copycat/data/SchemaProjectorTest.java -- diff --git

[19/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/f2031d40/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java -- diff --git

[17/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/417e283d/connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaOffsetBackingStore.java -- diff --git

[12/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/417e283d/copycat/api/src/main/java/org/apache/kafka/copycat/sink/SinkTask.java -- diff --git a/copycat/api/src/main/java/org/apache/kafka/copycat/sink/SinkTask.java

[14/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/f2031d40/connect/runtime/src/test/java/org/apache/kafka/connect/storage/KafkaOffsetBackingStoreTest.java -- diff --git

[16/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/f2031d40/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerSinkTaskThreadedTest.java -- diff --git

[19/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/417e283d/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java -- diff --git

[21/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/417e283d/connect/runtime/src/main/java/org/apache/kafka/connect/errors/AlreadyExistsException.java -- diff --git

[24/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/417e283d/connect/api/src/main/java/org/apache/kafka/connect/source/SourceRecord.java -- diff --git a/connect/api/src/main/java/org/apache/kafka/connect/source/SourceRecord.java

[08/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/417e283d/copycat/runtime/src/main/java/org/apache/kafka/copycat/runtime/WorkerSourceTask.java -- diff --git

[02/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/417e283d/copycat/runtime/src/test/java/org/apache/kafka/copycat/storage/KafkaOffsetBackingStoreTest.java -- diff --git

[06/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/f2031d40/copycat/runtime/src/main/java/org/apache/kafka/copycat/runtime/rest/entities/CreateConnectorRequest.java -- diff --git

[03/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/f2031d40/copycat/runtime/src/test/java/org/apache/kafka/copycat/runtime/distributed/WorkerCoordinatorTest.java -- diff --git

[25/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/417e283d/connect/api/src/main/java/org/apache/kafka/connect/data/Date.java -- diff --git a/connect/api/src/main/java/org/apache/kafka/connect/data/Date.java

[06/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/417e283d/copycat/runtime/src/main/java/org/apache/kafka/copycat/runtime/rest/entities/CreateConnectorRequest.java -- diff --git

[01/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

Repository: kafka Updated Branches: refs/heads/0.9.0 48013222f -> 417e283d6 http://git-wip-us.apache.org/repos/asf/kafka/blob/417e283d/tests/kafkatest/tests/connect_distributed_test.py -- diff --git

[26/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

KAFKA-2774: Rename Copycat to Kafka Connect Author: Ewen Cheslack-Postava Reviewers: Gwen Shapira Closes #456 from ewencp/kafka-2774-rename-copycat (cherry picked from commit f2031d40639ef34c1591c22971394ef41c87652c) Signed-off-by: Gwen Shapira Project:

[21/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/f2031d40/connect/runtime/src/main/java/org/apache/kafka/connect/errors/AlreadyExistsException.java -- diff --git

[07/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/417e283d/copycat/runtime/src/main/java/org/apache/kafka/copycat/runtime/distributed/DistributedHerder.java -- diff --git

[20/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/f2031d40/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java -- diff --git

[13/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/417e283d/copycat/api/src/main/java/org/apache/kafka/copycat/data/CopycatSchema.java -- diff --git a/copycat/api/src/main/java/org/apache/kafka/copycat/data/CopycatSchema.java

[25/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/f2031d40/connect/api/src/main/java/org/apache/kafka/connect/data/Date.java -- diff --git a/connect/api/src/main/java/org/apache/kafka/connect/data/Date.java

[18/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/f2031d40/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/CreateConnectorRequest.java -- diff --git

[16/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/417e283d/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerSinkTaskThreadedTest.java -- diff --git

[23/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/417e283d/connect/api/src/test/java/org/apache/kafka/connect/data/SchemaProjectorTest.java -- diff --git

[09/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/417e283d/copycat/runtime/src/main/java/org/apache/kafka/copycat/errors/AlreadyExistsException.java -- diff --git

[04/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/f2031d40/copycat/runtime/src/test/java/org/apache/kafka/copycat/runtime/WorkerSinkTaskThreadedTest.java -- diff --git

[13/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/f2031d40/copycat/api/src/main/java/org/apache/kafka/copycat/data/CopycatSchema.java -- diff --git a/copycat/api/src/main/java/org/apache/kafka/copycat/data/CopycatSchema.java

[05/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/f2031d40/copycat/runtime/src/main/java/org/apache/kafka/copycat/storage/KafkaOffsetBackingStore.java -- diff --git

[08/26] kafka git commit: KAFKA-2774: Rename Copycat to Kafka Connect

http://git-wip-us.apache.org/repos/asf/kafka/blob/f2031d40/copycat/runtime/src/main/java/org/apache/kafka/copycat/runtime/WorkerSourceTask.java -- diff --git