GitHub user apovzner opened a pull request:
https://github.com/apache/kafka/pull/1278
KAFKA-3597: Query ConsoleConsumer and VerifiableProducer if they shutdown
cleanly
Even if a test calls stop() on console_consumer or verifiable_producer, it
is still possible that producer
Github user apovzner closed the pull request at:
https://github.com/apache/kafka/pull/570
---
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 is
GitHub user apovzner opened a pull request:
https://github.com/apache/kafka/pull/1192
MINOR: ensure original use of prop_file in verifiable producer
This PR: https://github.com/apache/kafka/pull/958 fixed the use of
prop_file in the situation when we have multiple producers (before
GitHub user apovzner opened a pull request:
https://github.com/apache/kafka/pull/1015
KAFKA-3303: Pass partial record metadata to
ProducerInterceptor.onAcknowledgement on error
This is a KIP-42 followup.
Currently, If sending the record fails before it gets to the server
GitHub user apovzner opened a pull request:
https://github.com/apache/kafka/pull/980
KAFKA-3201: Added rolling upgrade system tests from 0.8 and 0.9 to 0.10
Three main tests:
1. Setup: Producer (0.8) â Kafka Cluster â Consumer (0.8)
First rolling bounce: Set
GitHub user apovzner opened a pull request:
https://github.com/apache/kafka/pull/958
KAFKA-3214: Added system tests for compressed topics
Added the following tests:
1. Extended TestVerifiableProducer (sanity check test) to test Trunk with
snappy compression (one producer/one
GitHub user apovzner opened a pull request:
https://github.com/apache/kafka/pull/951
KAFKA-3196: Added checksum and size to RecordMetadata and
ConsumerRecordetadata and ConsumerRecord
This is the second (remaining) part of KIP-42. See
https://cwiki.apache.org/confluence/display
GitHub user apovzner opened a pull request:
https://github.com/apache/kafka/pull/854
KAFKA-3162: Added producer and consumer interceptors
This is the most of the KIP-42: Producer and consumer interceptor. (Except
exposing CRC and record sizes to the interceptor, which is coming as
Github user apovzner closed the pull request at:
https://github.com/apache/kafka/pull/760
---
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 is
GitHub user apovzner reopened a pull request:
https://github.com/apache/kafka/pull/760
POC Producer Interceptor and simple C3 implementation of producer
interceptor.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/confluentinc
Github user apovzner closed the pull request at:
https://github.com/apache/kafka/pull/760
---
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 is
GitHub user apovzner opened a pull request:
https://github.com/apache/kafka/pull/760
POC Producer Interceptor and simple C3 implementation of producer
interceptor.
PR is for code review only (pre-KIP POC code).
What's missing:
1. We will specify all interceptor cl
GitHub user apovzner opened a pull request:
https://github.com/apache/kafka/pull/655
KAFKA-2896 Added system test for partition re-assignment
Partition re-assignment tests with and without broker failure.
You can merge this pull request into a Git repository by running:
$ git
GitHub user apovzner opened a pull request:
https://github.com/apache/kafka/pull/618
KAFKA-2825: Add controller failover to existing replication tests
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/apovzner/kafka kafka_2825_01
Github user apovzner closed the pull request at:
https://github.com/apache/kafka/pull/609
---
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 is
GitHub user apovzner opened a pull request:
https://github.com/apache/kafka/pull/610
KAFKA-1851 Using random file names for local kdc files to avoid conflicts.
I originally tried to solve the problem by using tempfile, and creating and
using scp() utility method that created a
GitHub user apovzner opened a pull request:
https://github.com/apache/kafka/pull/609
KAFKA-1851 Using random dir under /temp for local kdc files to avoid
conflicts.
when multiple test jobs are running.
I manually separated changes for KAFKA-2851 from this PR:
https
Github user apovzner closed the pull request at:
https://github.com/apache/kafka/pull/518
---
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 is
GitHub user apovzner opened a pull request:
https://github.com/apache/kafka/pull/570
KAFKA-2825, KAFKA-2852: Controller failover tests added to ducktape
replication tests and fix to temp dir
I closed an original pull request that contained previous comments by Geoff
(which are
GitHub user apovzner opened a pull request:
https://github.com/apache/kafka/pull/518
KAFKA-2825: Extended existing ducktape replication tests to include
controller failover
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
GitHub user apovzner opened a pull request:
https://github.com/apache/kafka/pull/472
KAFKA-2769: Multi-consumer integration tests for consumer assignment incl.
session timeouts and corresponding fixes
-- Refactored multi-consumer integration group assignment validation tests
for
Github user apovzner closed the pull request at:
https://github.com/apache/kafka/pull/440
---
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 is
GitHub user apovzner opened a pull request:
https://github.com/apache/kafka/pull/440
Do not merge: Multi-consumer integration tests for consumer group subsribe
and timeouts and corresponding fixes
A subset of changes for CPKAFKA-81 for initial review.
-- Refactored multi
GitHub user apovzner opened a pull request:
https://github.com/apache/kafka/pull/413
KAFKA-2737: Added single- and multi-consumer integration tests for
round-robin assignment
Two tests:
1. One consumer subscribes to 2 topics, each with 2 partitions; includes
adding and
GitHub user apovzner opened a pull request:
https://github.com/apache/kafka/pull/393
KAFKA-2714: Added integration tests for exceptional cases in fetching
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/apovzner/kafka cpkafka-84
Github user apovzner closed the pull request at:
https://github.com/apache/kafka/pull/384
---
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 is
GitHub user apovzner opened a pull request:
https://github.com/apache/kafka/pull/384
MINOR: Added integration tests for exceptional cases in fetching
1. When reset policy is NONE, verify that NoOffsetForPartitionException is
thrown if no initial position is set. Verify that
27 matches
Mail list logo
