GitHub user benstopford opened a pull request:
https://github.com/apache/kafka/pull/3468
KAFKA-5542: Improve Java doc for LeaderEpochFileCache.endOffsetFor()
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/benstopford/kafka
GitHub user benstopford opened a pull request:
https://github.com/apache/kafka/pull/2831
MINOR: KAFKA-5036 (points 2, 5): Refactor caching of Latest Epoch
This PR covers point (2) and point (5) from KAFKA-5036:
2. Currently, we update the leader epoch in epochCache after log
GitHub user benstopford opened a pull request:
https://github.com/apache/kafka/pull/2821
MINOR: CollectionUtils.groupDataByTopic in
OffsetsForLeaderEpochRequest/Response
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
Github user benstopford closed the pull request at:
https://github.com/apache/kafka/pull/2743
---
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 benstopford opened a pull request:
https://github.com/apache/kafka/pull/2808
KIP-101: Alter Replication Protocol to use Leader Epoch rather than High
Watermark for Truncation
This PR describes the addition of Partition Level Leader Epochs to messages
in Kafka as a
GitHub user benstopford opened a pull request:
https://github.com/apache/kafka/pull/2743
KIP-101: Alter Replication Protocol to use Leader Epoch rather than High
Watermark for Truncation
This PR describes the addition of Partition Level Leader Epochs to messages
in Kafka as a
GitHub user benstopford opened a pull request:
https://github.com/apache/kafka/pull/2734
KAFKA-4948: Failure in kafka.admin.DescribeConsumerGroupTest...
This test fails regularly when run on OSX (on my machine anyway). The fix
decreases the number of partitions in the consumer
GitHub user benstopford opened a pull request:
https://github.com/apache/kafka/pull/2698
MINOR: Increase Throttle lower bound assertion in throttling_test
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/benstopford/kafka
GitHub user benstopford opened a pull request:
https://github.com/apache/kafka/pull/2399
KAFKA 4596: Throttled Replica Reassignment Error
Fixes a logic error in the Reassignment process which throws an exception
if you don't rebalance all partitions.
You can merge this
GitHub user benstopford opened a pull request:
https://github.com/apache/kafka/pull/2034
KAFKA-4309: Allow "pluggable" properties in KafkaService in System Tests
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/benstop
GitHub user benstopford opened a pull request:
https://github.com/apache/kafka/pull/2033
Documentation for Throttled Replication
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/benstopford/kafka throttling-docs
Alternatively
GitHub user benstopford opened a pull request:
https://github.com/apache/kafka/pull/1997
KAFKA-4266: ReassignPartitionsClusterTest - Ensure ZK publication completed
before start
Increase the reliability of the one temporal comparison in
ReassignPartitionsClusterTest by imposing a
GitHub user benstopford opened a pull request:
https://github.com/apache/kafka/pull/1957
MINOR: Add Replication Quotas Test Rig
This test rig lives in the other.kafka package so isn't part of our
standard tests. It provides a convenient mechanism for measuring throt
GitHub user benstopford opened a pull request:
https://github.com/apache/kafka/pull/1951
MINOR: Rename property variables to match config
ThrottledLeaderReplicationRate* => LeaderReplicationThrottledRate*
ThrottledFollowerReplicationRate* => FollowerReplicationThrottl
GitHub user benstopford opened a pull request:
https://github.com/apache/kafka/pull/1950
MINOR: Add unit tests to the ReassignPartitionsCommand
Adds a bunch of tests to unit tests to the assignment command.
Moves the Rack aware test into its own class as it makes use of
GitHub user benstopford opened a pull request:
https://github.com/apache/kafka/pull/1932
KAFKA-4225: Replication Quotas: Control Leader & Follower Limit Separately
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/benstop
Github user benstopford closed the pull request at:
https://github.com/apache/kafka/pull/1928
---
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 benstopford opened a pull request:
https://github.com/apache/kafka/pull/1928
KAFKA-4225: Replication Quotas: Control Leader & Follower Limit Separately
See final commit.
(depends on https://github.com/apache/kafka/pull/1906)
You can merge this pull req
GitHub user benstopford opened a pull request:
https://github.com/apache/kafka/pull/1906
KAFKA 4216: Control Leader & Follower Throttled Replicas Separately
Splits the throttled replica configuration (the list of which replicas
should be throttled for each topic) into two. One
GitHub user benstopford opened a pull request:
https://github.com/apache/kafka/pull/1896
KAFKA-4200: Fix throttle argument in kafka-reassign-partitions.sh
Simple jira which alters two things:
1. kafka-reassign-partitions --verify prints Throttle was removed
regardless of
GitHub user benstopford opened a pull request:
https://github.com/apache/kafka/pull/1893
KAFKA-4178: Windows in Rate Calculation
ReplicationQuotas included a new Rate class which changed the way the
window is calculated. @junrao asked that we look to consolidate this. On
balance I
GitHub user benstopford opened a pull request:
https://github.com/apache/kafka/pull/1892
KAFKA-[TBD]: Make ReassignPartitionsTest System Test move data
The ReassignPartitionsTest system tests doesn't reassign any replicas (i.e.
move data).
This is a simple issue. It
GitHub user benstopford opened a pull request:
https://github.com/apache/kafka/pull/1881
KAFKA-4193: Fix for Intermittent failure in FetcherTest
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/benstopford/kafka KAFKA-4193
GitHub user benstopford opened a pull request:
https://github.com/apache/kafka/pull/1873
KAFKA-4184: Intermitant failures in
ReplicationQuotasTest.shouldBootstrapTwoBrokersWithFollowerThrottle
You can merge this pull request into a Git repository by running:
$ git pull
GitHub user benstopford opened a pull request:
https://github.com/apache/kafka/pull/1864
Kafka-4177: Remove ThrottledReplicationRateLimit from Server Config
This small PR pulls ThrottledReplicationRateLimit out of KafkaConfig and
puts it in a class that defines Dynamic Configs
GitHub user benstopford opened a pull request:
https://github.com/apache/kafka/pull/1776
KIP-73 - Replication Quotas
This applies to Replication Quotas
based on KIP-73
[()](https://cwiki.apache.org/confluence/display/KAFKA/KIP-73+Replication+Quotas)
originally motivated by
GitHub user benstopford opened a pull request:
https://github.com/apache/kafka/pull/1369
MINOR: Documentation for Rack Awareness
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/benstopford/kafka rack-awareness-docs
GitHub user benstopford opened a pull request:
https://github.com/apache/kafka/pull/956
Kafka 3270 Added some Happy Path Tests for the Reassign Partitions Command
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/benstopford/kafka
GitHub user benstopford opened a pull request:
https://github.com/apache/kafka/pull/924
KAFKA-3242: minor rename / logging change to Controller
KAFKA-3242: minor rename / logging change to references to 'adding
partitions' to indicate 'modifying partitions'
You
GitHub user benstopford opened a pull request:
https://github.com/apache/kafka/pull/667
KAFKA-2964: Split Security Rolling Upgrade Test by Client and Broker
Protocols
The core of this test is to ensure we evaluate enabling security in a
running cluster where we have different
GitHub user benstopford opened a pull request:
https://github.com/apache/kafka/pull/625
Add Rolling Upgrade Notes to Security Docs
And added info about the krb5.conf file as we don't appear to mention that
in the current docs
You can merge this pull request into a Git repos
GitHub user benstopford opened a pull request:
https://github.com/apache/kafka/pull/608
KAFKA-2915: Fix problem with System Tests that use bootstrap.servers
embedded in jinja files
Fixes problems in mirror maker and consumer tests
http://jenkins.confluent.io/job
GitHub user benstopford opened a pull request:
https://github.com/apache/kafka/pull/593
KAFKA-2899: (trivial) Log unexpected exceptions thrown when reading local
log
Currently we don't log exceptions raised when reading from the local log
which makes tracking down the cau
GitHub user benstopford reopened a pull request:
https://github.com/apache/kafka/pull/520
KAFKA-2824: MiniKDC based tests don't run in VirtualBox
This is a hack which works. Is there a better way?
Build of the replication_test.py running here:
http://jenkins.conflue
Github user benstopford closed the pull request at:
https://github.com/apache/kafka/pull/520
---
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 benstopford opened a pull request:
https://github.com/apache/kafka/pull/525
KAFKA-2791: removed deprecated properties
Removed support for BLOCK_ON_BUFFER_FULL_CONFIG (block.on.buffer.full)
Removed support for METADATA_FETCH_TIMEOUT_CONFIG
Removed support for
GitHub user benstopford opened a pull request:
https://github.com/apache/kafka/pull/520
KAFKA-2824: MiniKDC based tests don't run in VirtualBox
This is a hack which works. Is there a better way?
Build of the replication_test.py running here:
http://jenkins.confluent.i
GitHub user benstopford opened a pull request:
https://github.com/apache/kafka/pull/496
KAFKA-2771: Added rolling upgrade system test (docktape) for SSL
This still needs a final run of the full system test suite. I've run this
test and the replication_test.py (which is the
GitHub user benstopford opened a pull request:
https://github.com/apache/kafka/pull/351
KAFKA-2338: add force option to topic / config command so they can be
called programatically
Tiny change to add a force option to the topic and config commands so they
can be called
GitHub user benstopford opened a pull request:
https://github.com/apache/kafka/pull/322
KAFKA-2338: Warn on max.message.bytes change
- Both TopicCommand and ConfigCommand warn if message.max.bytes increases
- Log failures on the broker if replication gets stuck due to an
Github user benstopford closed the pull request at:
https://github.com/apache/kafka/pull/302
---
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 benstopford opened a pull request:
https://github.com/apache/kafka/pull/302
KAFKA-2638: Added default properties file to ConsumerPerformance
Blocker for SSL integration
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
GitHub user benstopford opened a pull request:
https://github.com/apache/kafka/pull/301
KAFKA-2637: Cipher suite setting should be configurable for SSL
Enables Cipher suite setting. Code was previously reviewed by @ijuma,
@harshach. Moving to an independent PR.
You can merge this
Github user benstopford closed the pull request at:
https://github.com/apache/kafka/pull/217
---
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 benstopford opened a pull request:
https://github.com/apache/kafka/pull/217
KAFKA-2431: Easier Testing of SSL
- Allow cipher suites to be specified relevant properties
- Avoid System.exit in ProducerPerformance so this can be externally invoked
- Add command line
GitHub user benstopford opened a pull request:
https://github.com/apache/kafka/pull/199
Small change to API doc for seekToEnd() to clarify lazy evaluation.
Small clarification to docs. Current behaviour could confuse when doing
something like:
consumer.seekToEnd
GitHub user benstopford reopened a pull request:
https://github.com/apache/kafka/pull/158
KAFKA-2453: Enable new consumer in EndToEndLatency
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/benstopford/kafka KAFKA-2453b
Github user benstopford closed the pull request at:
https://github.com/apache/kafka/pull/158
---
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 benstopford reopened a pull request:
https://github.com/apache/kafka/pull/158
KAFKA-2453: Enable new consumer in EndToEndLatency
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/benstopford/kafka KAFKA-2453b
Github user benstopford closed the pull request at:
https://github.com/apache/kafka/pull/158
---
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 benstopford reopened a pull request:
https://github.com/apache/kafka/pull/158
KAFKA-2453: Enable new consumer in EndToEndLatency
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/benstopford/kafka KAFKA-2453b
Github user benstopford closed the pull request at:
https://github.com/apache/kafka/pull/158
---
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 benstopford reopened a pull request:
https://github.com/apache/kafka/pull/158
KAFKA-2453: Enable new consumer in EndToEndLatency
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/benstopford/kafka KAFKA-2453b
Github user benstopford closed the pull request at:
https://github.com/apache/kafka/pull/158
---
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 benstopford reopened a pull request:
https://github.com/apache/kafka/pull/158
KAFKA-2453: Enable new consumer in EndToEndLatency
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/benstopford/kafka KAFKA-2453b
Github user benstopford closed the pull request at:
https://github.com/apache/kafka/pull/158
---
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 benstopford opened a pull request:
https://github.com/apache/kafka/pull/158
KAFKA-2453: Enable new consumer in EndToEndLatency
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/benstopford/kafka KAFKA-2453b
GitHub user benstopford opened a pull request:
https://github.com/apache/kafka/pull/144
Kafka 2015 - Enable ConsoleConsumer to use new consumer
This extends the original patch done by GZ to provide Console access to
both the new and old consumer API's. The code follows a pa
58 matches
Mail list logo
