7b3d1bf6a3
KAFKA-2867: Fix missing WorkerSourceTask synchronization and handling of InterruptException.
...
Author: Ewen Cheslack-Postava <me@ewencp.org>
Reviewers: Jun Rao <junrao@gmail.com>
Closes #566 from ewencp/kafka-2867-fix-source-sync-and-interrupt
2015-11-20 10:04:40 -08:00
0f00ec97ae
KAFKA-2859: Fix deadlock in WorkerSourceTask.
...
Author: Ewen Cheslack-Postava <me@ewencp.org>
Reviewers: Gwen Shapira
Closes #554 from ewencp/kafka-2859-deadlock-worker-source-task
2015-11-18 14:19:37 -08:00
f1169f1da8
KAFKA-2848; Use client SSL/SASL config utilities in Kafka Connect to avoid duplication of configs.
...
Author: Ewen Cheslack-Postava <me@ewencp.org>
Reviewers: Jun Rao <junrao@gmail.com>
Closes #539 from ewencp/kafka-2848-reuse-ssl-sasl-client-configs
2015-11-16 22:00:34 -08:00
1408c670ea
KAFKA-2807: Fix Kafka Connect packaging and move VerifiableSource/Sink into runtime jar.
...
Gradle does not handle subprojects with the same name (top-level tools vs
connect/tools) properly, making the dependency impossible to express correctly
since we need to move the ThroughputThrottler class into the top level tools
project. Moving the current set of tools into the runtime jar works fine since
they are only used for system tests at the moment.
Author: Ewen Cheslack-Postava <me@ewencp.org>
Reviewers: Gwen Shapira
Closes #512 from ewencp/kafka-2807-redux
2015-11-12 11:11:56 -08:00
c6b8de4e68
KAFKA-2807: Move ThroughputThrottler back to tools jar to fix upgrade tests.
...
Author: Ewen Cheslack-Postava <me@ewencp.org>
Reviewers: Gwen Shapira
Closes #499 from ewencp/kafka-2807-relocate-throughput-throttler
2015-11-11 15:55:12 -08:00
04827e6e99
KAFKA-2752: Follow up to fix checkstlye
...
Author: Grant Henke <granthenke@gmail.com>
Reviewers: Ewen Cheslack-Postava
Closes #492 from granthenke/fix
2015-11-10 15:57:02 -08:00
8db55618d5
KAFKA-2752: Add VerifiableSource/Sink connectors and rolling bounce Copycat system tests.
...
Author: Ewen Cheslack-Postava <me@ewencp.org>
Reviewers: Ben Stopford, Geoff Anderson, Guozhang Wang
Closes #432 from ewencp/kafka-2752-copycat-clean-bounce-test
2015-11-10 14:54:15 -08:00
403d89edea
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 <me@ewencp.org>
Reviewers: Gwen Shapira
Closes #486 from ewencp/kafka-2798-conflicting-herder-producer-consumer-configs
2015-11-10 11:07:26 -08:00
590a4616a1
KAFKA-2786: Only respond to SinkTask onPartitionsRevoked after the WorkerSinkTask has finished starting up.
...
Author: Ewen Cheslack-Postava <me@ewencp.org>
Reviewers: Gwen Shapira
Closes #476 from ewencp/kafka-2786-on-partitions-assigned-only-after-start
2015-11-09 20:43:07 -08:00
83eaf3284f
KAFKA-2379: Add basic documentation for Kafka Connect.
...
Author: Ewen Cheslack-Postava <me@ewencp.org>
Reviewers: Gwen Shapira
Closes #475 from ewencp/kafka-2379-connect-docs
2015-11-09 16:29:30 -08:00
75f2b8c8b4
KAFKA-2782: Fix KafkaBasedLogTest assertion and move it to the main test thread.
...
Author: Ewen Cheslack-Postava <me@ewencp.org>
Reviewers: Gwen Shapira
Closes #463 from ewencp/kafka-2782-fix-kafka-based-log-test-assertion
2015-11-09 10:39:34 -08:00
13ba57dcfc
KAFKA-2778: Use zero loss settings by default for Connect source producers.
...
Author: Ewen Cheslack-Postava <me@ewencp.org>
Reviewers: Gwen Shapira
Closes #459 from ewencp/kafka-2778-connect-source-zero-loss-settings
2015-11-09 10:36:57 -08:00
bc76e6704e
KAFKA-2775: Move exceptions into API package for Kafka Connect.
...
Author: Ewen Cheslack-Postava <me@ewencp.org>
Reviewers: Gwen Shapira
Closes #457 from ewencp/kafka-2775-exceptions-in-api-package
2015-11-09 10:27:18 -08:00
e9fc7b8c84
KAFKA-2776: Fix lookup of schema conversion cache size in JsonConverter.
...
Author: Ewen Cheslack-Postava <me@ewencp.org>
Reviewers: Gwen Shapira
Closes #458 from ewencp/kafka-2776-json-converter-cache-config-fix
2015-11-09 10:19:27 -08:00
f2031d4063
KAFKA-2774: Rename Copycat to Kafka Connect
...
Author: Ewen Cheslack-Postava <me@ewencp.org>
Reviewers: Gwen Shapira
Closes #456 from ewencp/kafka-2774-rename-copycat
2015-11-08 22:11:03 -08:00
Ewen Cheslack-Postava
Grant Henke