Repository: kafka
Updated Branches:
refs/heads/trunk a36befd81 - 68ad80f85
KAFKA-2415; Fix transient failure in LogRecoveryTest
Author: Jiangjie Qin becket@gmail.com
Author: Jiangjie Qin j...@jqin-ld1.linkedin.biz
Reviewers: Ismael Juma, Gwen Shapira
Closes #121 from
Repository: kafka
Updated Branches:
refs/heads/trunk 63b820c59 - 47c99f387
Minor: Fixes to Selector's javadoc
Author: Ismael Juma ism...@juma.me.uk
Closes #126 from ijuma/minor-selector-javadoc-fixes and squashes the following
commits:
a26f529 [Ismael Juma] Minor fixes to Selector's
Repository: kafka
Updated Branches:
refs/heads/trunk 3902dc024 - 04b0d870b
KAFKA-2429: Add annotations to mark classes as stable/unstable
This also marks the consumer as unstable to show an example of using these
annotations.
Author: Ewen Cheslack-Postava m...@ewencp.org
Reviewers: Gwen
Repository: kafka
Updated Branches:
refs/heads/trunk 786867c2e - 503bd3664
KAFKA-2436; log.retention.hours should be honored by LogManager
Author: Dong Lin lindon...@gmail.com
Reviewers: Joel Koshy, Gwen Shapira
Closes #142 from lindong28/KAFKA-2436
Project:
Repository: kafka
Updated Branches:
refs/heads/trunk 0b04f9f34 - e4fc456ab
KAFKA-2330: Vagrantfile sets global configs instead of per-provider override
configs; patched by Ewen Cheslack-Postava, reviewed by Geoff Anderson and Gwen
Shapira
Project:
Repository: kafka
Updated Branches:
refs/heads/trunk 3285a9c89 - 6acd37720
KAFKA-2457; Fix how the argument is passed to `compileScala`
Author: Ismael Juma ism...@juma.me.uk
Reviewers: Gwen Shapira
Closes #159 from ijuma/kafka-2457-fix
Project:
Repository: kafka
Updated Branches:
refs/heads/trunk 6acd37720 - 1d2ae89c5
KAFKA-2439; Add MirrorMaker service class for system tests
Added MirrorMaker service and a few corresponding sanity checks, as well as
necessary config template files. A few additional updates to accomodate the
Repository: kafka
Updated Branches:
refs/heads/trunk 63b89658b - 786867c2e
KAFKA-2438; add maxParallelForks to build.gradle to speedup tests.
Author: Sriharsha Chintalapani har...@hortonworks.com
Reviewers: Gwen Shapira
Closes #143 from harshach/KAFKA-2438
Project:
Repository: kafka
Updated Branches:
refs/heads/trunk e43c9aff9 - b7bd2978d
KAFKA-2100; Client Error doesn't preserve or display original server error code
when it is an unknown code; Reviewed by Gwen, Guozhang and Ewen
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit:
Repository: kafka
Updated Branches:
refs/heads/trunk cd3dc7a5c - 3c0963084
KAFKA-2386; increase timeouts for transient test failure in
ConsumerCoordinatorResponseTests
There are two race conditions in the test case
testGenerationIdIncrementsOnRebalance. First, a delay before the second join
Repository: kafka
Updated Branches:
refs/heads/trunk 9cefb2a0f - fc40016cf
KAFKA-2407: Only create log directory when it will be used
Author: Grant Henke granthe...@gmail.com
Reviewers: Gwen Shapira
Closes #115 from granthenke/log-fix and squashes the following commits:
de36138 [Grant
Repository: kafka
Updated Branches:
refs/heads/trunk b152c0604 - cd3dc7a5c
MINOR: Added to .gitignore Kafka server logs directory
When running Kafka server from sources, logs directory gets created in root of
repository, and kafka server logs end up there. Currently that directory is not
Repository: kafka
Updated Branches:
refs/heads/trunk a56a79055 - 7a666f7aa
KAFKA-2405; Don't kill the JVM on session establishment failure
As noted in the JIRA https://issues.apache.org/jira/browse/KAFKA-2405 currently
the KafkaHealthCheck causes the JVM to terminate in cases where session
Repository: kafka
Updated Branches:
refs/heads/trunk c8e62c981 - f6acfb089
http://git-wip-us.apache.org/repos/asf/kafka/blob/f6acfb08/copycat/runtime/src/test/java/org/apache/kafka/copycat/util/TestBackgroundThreadExceptionHandler.java
http://git-wip-us.apache.org/repos/asf/kafka/blob/f6acfb08/copycat/file/src/main/java/org/apache/kafka/copycat/file/FileStreamSinkConnector.java
--
diff --git
KAFKA-2366; Initial patch for Copycat
This is an initial patch implementing the basics of Copycat for KIP-26.
The intent here is to start a review of the key pieces of the core API and get
a reasonably functional, baseline, non-distributed implementation of Copycat in
place to get things
http://git-wip-us.apache.org/repos/asf/kafka/blob/f6acfb08/copycat/runtime/src/main/java/org/apache/kafka/copycat/runtime/Herder.java
--
diff --git
a/copycat/runtime/src/main/java/org/apache/kafka/copycat/runtime/Herder.java
http://git-wip-us.apache.org/repos/asf/kafka/blob/f6acfb08/copycat/data/src/main/java/org/apache/kafka/copycat/data/DataRuntimeException.java
--
diff --git
http://git-wip-us.apache.org/repos/asf/kafka/blob/f6acfb08/copycat/runtime/src/main/java/org/apache/kafka/copycat/storage/OffsetStorageWriter.java
--
diff --git
http://git-wip-us.apache.org/repos/asf/kafka/blob/f6acfb08/copycat/data/src/main/java/org/apache/kafka/copycat/data/SchemaBuilder.java
--
diff --git
a/copycat/data/src/main/java/org/apache/kafka/copycat/data/SchemaBuilder.java
Author: gwenshap
Date: Sat Aug 15 02:18:00 2015
New Revision: 1696013
URL: http://svn.apache.org/r1696013
Log:
KAFKA-2433; Remove documentation on dead configuration item:
replica.lag.max.messages; by Stepehn Powis
Modified:
kafka/site/083/configuration.html
Modified: kafka/site/083
Repository: kafka
Updated Branches:
refs/heads/trunk 7a666f7aa - 9cefb2a0f
KAFKA-2288; Follow-up to KAFKA-2249 - reduce logging and testing; Reviewd by
Jun Rao
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/9cefb2a0
Repository: kafka
Updated Branches:
refs/heads/trunk fd3b4cc41 - 18adec7ed
KAFKA-2344; kafka-merge-pr improvements
The first 4 commits are adapted from changes that have been done to the Spark
version and the last one is the feature that gwenshap asked for.
Author: Ismael Juma ism
Repository: kafka
Updated Branches:
refs/heads/trunk 18adec7ed - 66c8647d8
KAFKA-2355; Add an unit test to validate the deletion of a partition marked as
deleted; patched by Edward Ribeiro, reviewed by Ashish Singh, Ismael Juma and
Grant Henke
Project:
Repository: kafka
Updated Branches:
refs/heads/trunk bdbb9672f - a7e0ac365
KAFKA-2198: kafka-topics.sh exits with 0 status on failures; patched by
Manikumar Reddy reviewed by Gwen Shapira
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit:
Repository: kafka
Updated Branches:
refs/heads/trunk 15cba9f00 - a5b11886d
KAFKA-2345; Attempt to delete a topic already marked for deletion throws
ZkNodeExistsException; patched by Ashish Singh; reviewed by Sriharsha
Chintalapani and Ismael Juma
Project:
Repository: kafka
Updated Branches:
refs/heads/trunk 846362724 - 1d2bd6284
KAFKA-2337; Verify that metric names will not collide when creating new
topics; patched by Grant Henke; reviewed by Edward Ribeiro, Ashish Singh and
Gwen Shapira
Project:
Repository: kafka
Updated Branches:
refs/heads/trunk 1d2bd6284 - 204089046
KAFKA-2328; merge-kafka-pr.py script should not leave user in a detached branch
The right command to get the branch name is `git rev-parse --abbrev-ref HEAD`
instead of `git rev-parse HEAD`. The latter gives the
Repository: kafka
Updated Branches:
refs/heads/trunk 0da654761 -> e0ca8fdd7
MINOR: update to correct clock skew
ewencp
Updated the provisioning script to install ntp daemon.
Author: Geoff Anderson
Reviewers: Gwen Shapira
Closes #383 from
Repository: kafka
Updated Branches:
refs/heads/trunk e6f9b9e47 -> fc4ef4791
KAFKA-2645: Document potentially breaking changes in the release noteâ¦
â¦s for 0.9.0
Author: Grant Henke
Reviewers: Gwen Shapira, Guozhang Wang
Closes #337 from granthenke/docs
Project:
Repository: kafka
Updated Branches:
refs/heads/trunk 2e4aed707 -> 2fd645ac2
KAFKA-2452: Add new consumer option to mirror maker.
Author: Jiangjie Qin
Reviewers: Ben Stopford, Guozhang Wang
Closes #266 from becketqin/KAFKA-2452
Project:
Repository: kafka
Updated Branches:
refs/heads/trunk fc4ef4791 -> 2e4aed707
KAFKA-2516: Rename o.a.k.client.tools to o.a.k.tools
Author: Grant Henke
Reviewers: Gwen Shapira, Ewen Cheslack-Postava
Closes #310 from granthenke/tools-packaging
Project:
Repository: kafka
Updated Branches:
refs/heads/trunk 2fd645ac2 -> d21cb66e7
KAFKA-2447: Add capability to KafkaLog4jAppender to be able to use SSL
Author: Ashish Singh
Reviewers: Gwen Shapira, Ismael Juma
Closes #175 from SinghAsDev/KAFKA-2447
Project:
Repository: kafka
Updated Branches:
refs/heads/trunk 9855bb9c6 -> 8838fa801
MINOR: KAFKA-2371 follow-up, DistributedHerder should wakeup WorkerGroupMember
after assignment to ensure work is started immediately
Author: Ewen Cheslack-Postava
Reviewers: Gwen Shapira
Closes
Repository: kafka
Updated Branches:
refs/heads/trunk aa56dfb9e -> 701c46b3a
KAFKA-2671: Enable starting Kafka server with a Properties object
Author: Ashish Singh
Reviewers: Eno Thereska, Gwen Shapira
Closes #330 from SinghAsDev/KAFKA-2671
Project:
Repository: kafka
Updated Branches:
refs/heads/trunk 2e6177359 -> 6f2f1f984
KAFKA-2626: Handle null keys and value validation properly in
OffsetStorageWriter.
Author: Ewen Cheslack-Postava
Reviewers: Gwen Shapira
Closes #345 from
KAFKA-2371: Add distributed support for Copycat.
This adds coordination between DistributedHerders using the generalized consumer
support, allowing automatic balancing of connectors and tasks across workers. A
few pieces that require interaction between workers (resolving config
inconsistencies,
Repository: kafka
Updated Branches:
refs/heads/trunk 21443f214 -> 2e6177359
http://git-wip-us.apache.org/repos/asf/kafka/blob/2e617735/copycat/runtime/src/test/java/org/apache/kafka/copycat/runtime/distributed/DistributedHerderTest.java
http://git-wip-us.apache.org/repos/asf/kafka/blob/2e617735/copycat/runtime/src/main/java/org/apache/kafka/copycat/runtime/distributed/DistributedHerderConfig.java
--
diff --git
Repository: kafka
Updated Branches:
refs/heads/trunk 590a4616a -> fe11488a7
KAFKA-2797: Only run rat when in the .git repository since it require s the
.gitignore to generate the list of files to ignore
Author: Ewen Cheslack-Postava
Reviewers: Gwen Shapira
Closes #485
Repository: kafka
Updated Branches:
refs/heads/0.9.0 a621677be -> 528d555fc
KAFKA-2797: Only run rat when in the .git repository since it require s the
.gitignore to generate the list of files to ignore
Author: Ewen Cheslack-Postava
Reviewers: Gwen Shapira
Closes #485
Repository: kafka
Updated Branches:
refs/heads/0.9.0 528d555fc -> 69f2ad8e2
KAFKA-2792: Don't wait for a response to the leave group message when closing
the new consumer.
Author: Ewen Cheslack-Postava
Reviewers: Onur Karaman, Gwen Shapira
Closes #480 from
Repository: kafka
Updated Branches:
refs/heads/trunk fe11488a7 -> ae5a5d7c0
KAFKA-2792: Don't wait for a response to the leave group message when closing
the new consumer.
Author: Ewen Cheslack-Postava
Reviewers: Onur Karaman, Gwen Shapira
Closes #480 from
Repository: kafka
Updated Branches:
refs/heads/trunk ae5a5d7c0 -> 403d89ede
KAFKA-2798: Use prefixedd configurations for Kafka Connect producer and
consumer settings so they do not conflict with the distributed herder's
settings.
Author: Ewen Cheslack-Postava
Reviewers:
Repository: kafka
Updated Branches:
refs/heads/0.9.0 69f2ad8e2 -> dd8a870e4
KAFKA-2798: Use prefixedd configurations for Kafka Connect producer and
consumer settings so they do not conflict with the distributed herder's
settings.
Author: Ewen Cheslack-Postava
Reviewers:
Repository: kafka
Updated Branches:
refs/heads/trunk 60c06734b -> 64a1bfeb9
KAFKA-2793: Use ByteArrayDeserializer instead of StringDeserializer for keys in
ConsoleConsumer with new consumer.
Author: Ewen Cheslack-Postava
Reviewers: Gwen Shapira
Closes #482 from
Repository: kafka
Updated Branches:
refs/heads/0.9.0 501ac0282 -> 75db96e42
KAFKA-2793: Use ByteArrayDeserializer instead of StringDeserializer for keys in
ConsoleConsumer with new consumer.
Author: Ewen Cheslack-Postava
Reviewers: Gwen Shapira
Closes #482 from
Repository: kafka
Updated Branches:
refs/heads/trunk 359be3a68 -> a87b97822
MINOR: remove old producer in config sections to align with APIs
Author: Guozhang Wang
Reviewers: Gwen Shapira
Closes #468 from guozhangwang/WikiUpdate
Project:
Repository: kafka
Updated Branches:
refs/heads/trunk bc76e6704 -> 13ba57dcf
KAFKA-2778: Use zero loss settings by default for Connect source producers.
Author: Ewen Cheslack-Postava
Reviewers: Gwen Shapira
Closes #459 from
KAFKA-2783; Drop outdated hadoop contrib modules
Author: Grant Henke
Reviewers: Gwen Shapira
Closes #466 from granthenke/drop-contrib
(cherry picked from commit 69af573b35f04657e31f60e636aba19ffa0b2c84)
Signed-off-by: Gwen Shapira
Project:
Repository: kafka
Updated Branches:
refs/heads/trunk a24f9a23a -> e9fc7b8c8
KAFKA-2776: Fix lookup of schema conversion cache size in JsonConverter.
Author: Ewen Cheslack-Postava
Reviewers: Gwen Shapira
Closes #458 from ewencp/kafka-2776-json-converter-cache-config-fix
Repository: kafka
Updated Branches:
refs/heads/0.9.0 f22ea2970 -> e176fcc7f
http://git-wip-us.apache.org/repos/asf/kafka/blob/e176fcc7/contrib/hadoop-producer/README.md
--
diff --git a/contrib/hadoop-producer/README.md
Repository: kafka
Updated Branches:
refs/heads/trunk 2b04004de -> bc76e6704
KAFKA-2775: Move exceptions into API package for Kafka Connect.
Author: Ewen Cheslack-Postava
Reviewers: Gwen Shapira
Closes #457 from ewencp/kafka-2775-exceptions-in-api-package
Project:
Repository: kafka
Updated Branches:
refs/heads/0.9.0 4069011ee -> 0d2fdfa81
KAFKA-2782: Fix KafkaBasedLogTest assertion and move it to the main test thread.
Author: Ewen Cheslack-Postava
Reviewers: Gwen Shapira
Closes #463 from
Repository: kafka
Updated Branches:
refs/heads/trunk 13ba57dcf -> 75f2b8c8b
KAFKA-2782: Fix KafkaBasedLogTest assertion and move it to the main test thread.
Author: Ewen Cheslack-Postava
Reviewers: Gwen Shapira
Closes #463 from
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
Repository: kafka
Updated Branches:
refs/heads/trunk 2802bd081 -> 969d0cb0a
KAFKA-2826: Make Kafka Connect ducktape services easier to extend.
Author: Ewen Cheslack-Postava
Reviewers: Gwen Shapira
Closes #522 from ewencp/kafka-2826-extensible-connect-services
Project:
Repository: kafka
Updated Branches:
refs/heads/0.9.0 c5965820a -> d04a918a2
MINOR: Increase timeouts for Kafka Connect system test service to make tests
more reliable on wimpy nodes.
Author: Ewen Cheslack-Postava
Reviewers: Gwen Shapira
Closes #514 from
Repository: kafka
Updated Branches:
refs/heads/0.9.0 c4e069ae5 -> e8f92d620
MINOR: Tuned timeout parameter to reduce chance of transient failure
Increased timeout in downstream consumer doing validation step. This addresses
a transient failure case in mirror maker tests with mirror maker
Repository: kafka
Updated Branches:
refs/heads/trunk da9733091 -> 4511aeebc
Minor: Missing License
Author: Sriharsha Chintalapani
Reviewers: Gwen Shapira
Closes #524 from harshach/missing-license
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit:
Repository: kafka
Updated Branches:
refs/heads/0.9.0 cb0de177c -> 3e133c4ee
Minor: Missing License
Author: Sriharsha Chintalapani
Reviewers: Gwen Shapira
Closes #524 from harshach/missing-license
(cherry picked from commit 4511aeebc3e37a3d9e2ebeabbd6bbfd16d681719)
Repository: kafka
Updated Branches:
refs/heads/trunk a8ccdc615 -> c6b8de4e6
KAFKA-2807: Move ThroughputThrottler back to tools jar to fix upgrade tests.
Author: Ewen Cheslack-Postava
Reviewers: Gwen Shapira
Closes #499 from ewencp/kafka-2807-relocate-throughput-throttler
Repository: kafka
Updated Branches:
refs/heads/trunk 370ce2b4b -> ab5ac264a
KAFKA-2690: Hide passwords while logging the config.
Added PASSWORD_STRING in ConfigDef that returns "[hidden]" when method toString
is invoked.
Author: Jakub Nowak
Reviewers: Ismael
Repository: kafka
Updated Branches:
refs/heads/0.9.0 98124930f -> c5965820a
KAFKA-2690: Hide passwords while logging the config.
Added PASSWORD_STRING in ConfigDef that returns "[hidden]" when method toString
is invoked.
Author: Jakub Nowak
Reviewers: Ismael
Repository: kafka
Updated Branches:
refs/heads/0.9.0 0ea17e959 -> 1828b8e52
KAFKA-2790: doc improvements
Author: Gwen Shapira <csh...@gmail.com>
Reviewers: Jun Rao, Guozhang Wang
Closes #491 from gwenshap/KAFKA-2790
(cherry picked from commit a8ccdc6154a1e10982cb80df82e8661
Repository: kafka
Updated Branches:
refs/heads/trunk bce664b42 -> 590a4616a
KAFKA-2786: Only respond to SinkTask onPartitionsRevoked after the
WorkerSinkTask has finished starting up.
Author: Ewen Cheslack-Postava
Reviewers: Gwen Shapira
Closes #476 from
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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:
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
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
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
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
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
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
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
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
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
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
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
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
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
1 - 100 of 636 matches
Mail list logo