GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/879
MINOR: Add note about which files need to be edited when updating the
version number
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ewencp
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/770
KAFKA-3080: Fix ConsoleConsumerTest by checking version when service is
started
The MessageFormatter being used was only introduced as of 0.9.0.0. The Kafka
version in some tests is changed
Github user ewencp commented on the pull request:
https://github.com/apache/kafka-site/pull/8#issuecomment-171009732
LGTM, thanks.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have
Github user ewencp closed the pull request at:
https://github.com/apache/kafka/pull/727
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/727
MINOR: Update version to 0.9.0.1-SNAPSHOT
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ewencp/kafka minor-0.9.0.1-SNAPSHOT
Alternatively you
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/599
KAFKA-2906: Fix Connect javadocs, restrict only to api subproject, and
clean up javadoc warnings.
You can merge this pull request into a Git repository by running:
$ git pull https
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/566
KAFKA-2867: Fix missing WorkerSourceTask synchronization and handling of
InterruptException.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/565
MINOR: Fix typo in sample Vagrantfile.local for AWS system tests
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ewencp/kafka fix-aws-vagrantfile
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/554
KAFKA-2859: Fix deadlock in WorkerSourceTask.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ewencp/kafka
kafka-2859-deadlock-worker-source
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/539
KAFKA-2848: Use client SSL/SASL config utilities in Kafka Connect to avoid
duplication of configs.
You can merge this pull request into a Git repository by running:
$ git pull https
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/517
KAFKA-2814: Make Kafka Connect system test REST requests use hostname that
is compatible with running under AWS.
You can merge this pull request into a Git repository by running:
$ git pull
Github user ewencp closed the pull request at:
https://github.com/apache/kafka/pull/514
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/522
KAFKA-2826: Make Kafka Connect ducktape services easier to extend.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ewencp/kafka
kafka-2826
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/514
MINOR: Increase timeouts for Kafka Connect system test service to make
tests more reliable on wimpy nodes.
You can merge this pull request into a Git repository by running:
$ git pull https
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/512
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
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/485
KAFKA-2797: Only run rat when in the .git repository since it require s the
.gitignore to generate the list of files to ignore
You can merge this pull request into a Git repository by running
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/486
KAFKA-2798: Use prefixedd configurations for Kafka Connect producer and
consumer settings so they do not conflict with the distributed herder's
settings.
You can merge this pull request into a Git
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/494
KAFKA-2803: Add hard bounce system test for Kafka Connect.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ewencp/kafka
kafka-2803-connect-hard
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/482
KAFKA-2793: Use ByteArrayDeserializer instead of StringDeserializer for
keys in ConsoleConsumer with new consumer.
You can merge this pull request into a Git repository by running:
$ git pull
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/463
KAFKA-2782: Fix KafkaBasedLogTest assertion and move it to the main test
thread.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ewencp/kafka
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/461
KAFKA-2781: Only require signing artifacts when uploading archives.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ewencp/kafka kafka-2781
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/480
KAFKA-2792: Don't wait for a response to the leave group message when
closing the new consumer.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/475
KAFKA-2379: Add basic documentation for Kafka Connect.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ewencp/kafka kafka-2379-connect-docs
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/473
KAFKA-2785: Include Kafka Connect jars in releaseTarGz.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ewencp/kafka
kafka-2785-include-copycat
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/476
KAFKA-2786: Only respond to SinkTask onPartitionsRevoked after the
WorkerSinkTask has finished starting up.
You can merge this pull request into a Git repository by running:
$ git pull https
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/456
KAFKA-2774: Rename Copycat to Kafka Connect
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ewencp/kafka kafka-2774-rename-copycat
Alternatively
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/459
KAKFA-2778: Use zero loss settings by default for Connect source producers.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ewencp/kafka
kafka
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/458
KAFKA-2776: Fix lookup of schema conversion cache size in JsonConverter.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ewencp/kafka
kafka-2776
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/457
KAFKA-2775: Move exceptions into API package for Kafka Connect.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ewencp/kafka
kafka-2775
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/450
KAFKA-2480: Handle retriable and non-retriable exceptions thrown by sink
tasks.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ewencp/kafka
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/444
KAFKA-2764: Change use of Properties in Copycat to Maps.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ewencp/kafka kafka-2764-maps
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/443
KAFKA-2713: Run task start and stop methods in worker threads so they
execute in parallel and cannot block the herder thread.
You can merge this pull request into a Git repository by running
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/446
KAFKA-2765: Add versions to Copycat Connector and Task interfaces and log
versions when instantiating connectors and tasks.
You can merge this pull request into a Git repository by running
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/432
KAFKA-2572: Add VerifiableSource/Sink connectors and rolling bounce Copycat
system tests.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ewencp
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/431
KAFKA-2748: Ensure sink tasks commit offsets upon rebalance and rewind if
the SinkTask flush fails.
Also fix the incorrect consumer group ID setting which was giving each task
its
own group
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/421
KAFKA-2742: Fix SourceTaskOffsetCommitter to handle removal of commit tasks
when they are already in progress.
You can merge this pull request into a Git repository by running:
$ git pull
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/420
KAFKA-2741: Make SourceTaskContext and SinkTaskContext interfaces and keep
implementations in runtime jar.
You can merge this pull request into a Git repository by running:
$ git pull https
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/423
KAFKA-2744: Commit source task offsets after task is completely stopped to
ensure no additional messages are processed during the offset commit when
stopping tasks for rebalancing.
You can merge
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/422
KAFKA-2743: Make forwarded task reconfiguration requests asynchronous, run
on a separate thread, and backoff before retrying when they fail.
You can merge this pull request into a Git repository
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/378
KAFKA-2369: Add REST API for Copycat.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ewencp/kafka kafka-2369-copycat-rest-api
Alternatively you
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/377
MINOR: Fix missing copyright in config file added in KAFKA-2640.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ewencp/kafka minor-jaas-config
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/360
MINOR: KAFKA-2371 follow-up, DistributedHerder should wakeup
WorkerGroupMember after assignment to ensure work is started immediately
You can merge this pull request into a Git repository
Github user ewencp closed the pull request at:
https://github.com/apache/kafka/pull/344
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/345
KAFKA-2626: Handle null keys and value validation properly in
OffsetStorageWriter.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ewencp/kafka
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/344
KAFKA-2365: Handle null keys and value validation properly in
OffsetStorageWriter.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ewencp/kafka
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/333
KAFKA-2667: Fix transient error in KafkaBasedLogTest.
The test required a specific sequence of events for each Consumer.poll()
call,
but the MockConsumer.waitForPollThen() method could
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/331
MINOR: Capture stderr in ConsumerPerformanceService.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ewencp/kafka
minor-capture-consumer
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/321
KAFKA-2371: Add distributed support for Copycat.
This adds coordination between DistributedHerders using the generalized
consumer
support, allowing automatic balancing of connectors and tasks
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/293
KAFKA-2613: Make maxParallelForks configurable via Gradle config so it can
be turned down on shared build infrastructure.
You can merge this pull request into a Git repository by running
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/291
MINOR: Fix exception message in Copycat's Time logical type.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ewencp/kafka fixup-time-logical-type
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/285
KAFKA-2622: Add Time logical type for Copycat.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ewencp/kafka kafka-2622-time-logical-type
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/281
KAFKA-2476: Add Decimal, Date, and Timestamp logical types.
To support Decimal, this also adds support for schema parameters, which is
an
extra set of String key value pairs which provide extra
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/249
KAFKA-2482: Allow sink tasks to get their current assignment, as well as
pause and resume topic partitions.
You can merge this pull request into a Git repository by running:
$ git pull https
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/251
MINOR: Fix FileStreamSourceTask to create the reader around System.in when
using stdin as the input source.
You can merge this pull request into a Git repository by running:
$ git pull https
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/248
HOTFIX: Checkstye fixes follow up for KAKFA-2531.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ewencp/kafka hotfix-kafka-2531-checkstyle
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/250
KAFKA-2474: Add caching of JSON schema conversions to JsonConverter.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ewencp/kafka
kafka-2474
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/241
KAFKA-2372: Add Kafka-backed storage of Copycat configs.
This also adds some other needed infrastructure for distributed Copycat,
most
importantly the DistributedHerder, and refactors some code
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/202
KAFKA-2373: Add Kafka-backed offset storage for Copycat.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ewencp/kafka
kafka-2373-copycat
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/172
KAFKA-2475: Make Copycat only have a Converter class instead of Serializer,
Deserializer, and Converter.
The Converter class now translates directly between byte[] and Copycat's
data
API instead
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/163
KAFKA-2367: Add Copycat runtime data API.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ewencp/kafka
kafka-2367-copycat-runtime-data-api
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/150
KAFKA-2377: Add basic system test for copycat using source and sink file
connectors.
Tests standalone mode by running separate source and sink connectors,
catting
data into the source file
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/140
KAFKA-1782: Follow up - add missing @Test annotations.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ewencp/kafka kafka-1782-followup
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/133
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.
You can merge this pull request into a Git
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/135
KAFKA-Junit3 Misusage
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ewencp/kafka kafka-1782-junit3-misusage
Alternatively you can review
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/99
KAFKA-2366 [WIP]; 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
101 - 165 of 165 matches
Mail list logo
