GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/4312
MINOR: Increase number of messages in replica verification tool test
Increase the number of messages produced to make the test more reliable.
The test failed in a recent build and also fails
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/4303
KAFKA-6319: Quote strings stored in JSON configs
This is required for ACLs where SSL principals contain special characters
(e.g. comma) that are escaped using backslash. The strings need
Github user rajinisivaram closed the pull request at:
https://github.com/apache/kafka/pull/4294
---
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/4294
MINOR: Include client-id in client authentication failure error messages
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/4263
KAFKA-6241: Enable dynamic updates of broker SSL keystore
Enable dynamic broker configuration (see KIP-225 for details). Includes
- Base implementation to allow specific broker configs
Github user rajinisivaram closed the pull request at:
https://github.com/apache/kafka/pull/4199
---
Github user rajinisivaram closed the pull request at:
https://github.com/apache/kafka/pull/4203
---
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/4203
MINOR: Update version in docs for 0.11.0.2 release
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rajinisivaram/kafka version-update
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka-site/pull/108
Add Rajini's keys
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rajinisivaram/kafka-site add-key
Alternatively you can review
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/4199
KAFKA-6164; Shutdown quota managers if other components fail to start
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rajinisivaram/kafka
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/4193
KAFKA-6185: Remove channels from explictlyMutedChannels set when closed
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rajinisivaram
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/4187
MINOR: Handle error metrics removal during shutdown
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rajinisivaram/kafka MINOR-metrics
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/4181
KAFKA-6164: Shutdown quota managers if other components fail to start
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rajinisivaram/kafka
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/4140
KAFKA-6131: Use atomic putIfAbsent to create txn marker queues
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rajinisivaram/kafka
KAFKA
Github user rajinisivaram closed the pull request at:
https://github.com/apache/kafka/pull/4121
---
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/4122
KAFKA-6096: Add multi-threaded tests for group coordinator, txn manager
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rajinisivaram
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/4121
Kafka 6042: Use state write lock for delayed txn operations
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rajinisivaram/kafka KAFKA
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/4103
KAFKA-6042: Avoid deadlock between two groups with delayed operations
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rajinisivaram/kafka
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/4099
MINOR: Use ObjectName.quote instead of URL-encoding for JMX metric tags
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rajinisivaram
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/4026
KAFKA-5746: Document new broker metrics added for health checks
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rajinisivaram/kafka MINOR
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/4018
KAFKA-6010: Relax record conversion time test to avoid build failure
For record conversion tests, check time >=0 since conversion times may be
too small to be measured accurately. Si
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/4015
KAFKA-6004: Allow authentication providers to override error message
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rajinisivaram/kafka
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/4014
KAFKA-5738: Upgrade note for cumulative count metric (KIP-187)
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rajinisivaram/kafka MINOR
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/4013
KAFKA-4764: Upgrade notes for authentication failure handling (KIP-152)
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rajinisivaram
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/3991
KAFKA-5968: Create/remove request metrics during broker startup/shutdown
Replaces the static `RequestMetrics` object with a class so that metrics
are created and removed during broker startup
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/3956
KAFKA-5970: Avoid locking group in operations that lock DelayedProduce
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rajinisivaram
Github user rajinisivaram closed the pull request at:
https://github.com/apache/kafka/pull/2165
---
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/3928
KAFKA-5947: Handle authentication failure in admin client, txn producer
1. Raise AuthenticationException for authentication failures in admin client
2. Handle AuthenticationException
Github user rajinisivaram closed the pull request at:
https://github.com/apache/kafka/pull/3922
---
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/3922
Kafka 5854: Handle authentication failures in KafkaAdminClient
This is currently on top of the commits from #3832.
You can merge this pull request into a Git repository by running
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/3918
KAFKA-5920: Handle SSL handshake failures as authentication exceptions
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rajinisivaram
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/3882
MINOR: Add metric templates for sender/fetcher rate totals
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rajinisivaram/kafka
MINOR
Github user rajinisivaram closed the pull request at:
https://github.com/apache/kafka/pull/2546
---
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/3836
KAFKA-5872: Fix transient failure in SslSelectorTest.testMuteOnOOM
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rajinisivaram/kafka
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/3823
MINOR: Fix transient failure in
SelectorTest.testCloseConnectionInClosingState
`SelectorTest.testCloseConnectionInClosingState` creates a channel with
some staging receives and moves time
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/3792
KAFKA-5837: Set defaults for ReassignPartitionsCommand correctly
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rajinisivaram/kafka
Github user rajinisivaram closed the pull request at:
https://github.com/apache/kafka/pull/3773
---
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 rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/3773
MINOR: Fix unit test failures from last commit, cherry-pick fix for SASL
principal
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/3712
MINOR: Fix transient failure in SocketServerTest.testConnectionIdReuse
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rajinisivaram
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/3708
[WIP] KAFKA-4764: Wrap SASL tokens in Kafka headers to improve diagnostics
SASL handshake protocol changes from KIP-152.
You can merge this pull request into a Git repository by running
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/3705
[WIP] KAFKA-5746: Add new metrics to support health checks
This is currently built on top of PR #3673
You can merge this pull request into a Git repository by running:
$ git pull https
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/3686
[WIP] KAFKA-5738: Add cumulative count for rate metrics
Implementation of
https://cwiki.apache.org/confluence/display/KAFKA/KIP-187+-+Add+cumulative+count+metric+for+all+Kafka+rate+metrics
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/3668
KAFKA-5679: Add logging for broker termination due to SIGTERM or SIGINT
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rajinisivaram
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/3548
KAFKA-5607: Improve error handling in SocketServer to avoid issues later
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rajinisivaram
GitHub user rajinisivaram reopened a pull request:
https://github.com/apache/kafka/pull/3530
KAFKA-5595: Ensure client connection ids are not reused too quickly
When there are broker delays that cause a response to take longer than
`connections.max.idle.ms`, connections may
Github user rajinisivaram closed the pull request at:
https://github.com/apache/kafka/pull/3530
---
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 rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/3530
KAFKA-5595: Ensure client connection ids are not reused too quickly
On the broker, if client ports are reused when response to a closed
connection is outstanding, broker may send
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/3529
MINOR: Use correct connectionId in error message
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rajinisivaram/kafka MINOR-log-connection
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/3526
KAFKA-5587: Remove channel only after staged receives are delivered
When idle connections are closed, ensure that channels with staged receives
are retained in `closingChannels` until all
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/3483
MINOR: Wait for tasks to terminate to avoid exception in test teardown
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rajinisivaram
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/3471
MINOR: Add test brokers to list as they are created to ensure cleanup
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rajinisivaram/kafka
Github user rajinisivaram closed the pull request at:
https://github.com/apache/kafka/pull/3334
---
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 rajinisivaram reopened a pull request:
https://github.com/apache/kafka/pull/3303
KAFKA-5402: Avoid creating quota related metrics if quotas not enabled
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rajinisivaram
Github user rajinisivaram closed the pull request at:
https://github.com/apache/kafka/pull/3303
---
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 rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/3334
MINOR: Fix ConsumerBounceTest to wait for consumer close
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rajinisivaram/kafka MINOR-more
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/3317
MINOR: Clean up in DeleteConsumerGroupTest even if test fails
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rajinisivaram/kafka
MINOR
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/3315
MINOR: Generate deprecated warning for static default quota config
The default client-id bandwidth quota config properties have been marked
deprecated in the doc, but a warning may be useful
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/3314
KAFKA-5439: Verify that no unexpected threads are left behind in tests
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rajinisivaram
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/3304
KAFKA-5433: Close SimpleAclAuthorizer in test to close ZK client
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rajinisivaram/kafka
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/3303
KAFKA-5402: Avoid creating quota related metrics if quotas not enabled
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rajinisivaram
Github user rajinisivaram closed the pull request at:
https://github.com/apache/kafka/pull/3253
---
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 rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/3246
KAFKA-4948: Wait for offset commit in test to fix transient failure
`DescribeConsumerGroupTest#testDescribeExistingGroupWithNoMembersWithNewConsumer`
shuts down the consumer executor thread
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/3238
KAFKA-5380: Fix transient failure in KafkaConsumerTest, close consumers
In `KafkaConsumer#testChangingRegexSubscription`, keep metadata updated
with both topics since heartbeat thread may
Github user rajinisivaram closed the pull request at:
https://github.com/apache/kafka/pull/3209
---
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 rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/3209
KAFKA-5345; Close KafkaClient when streams client is closed
Cherry-pick KAFKA-5345 to 0.10.2
You can merge this pull request into a Git repository by running:
$ git pull https
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/3208
KAFKA-5325: Avoid and handle exceptions for Kerberos re-login
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rajinisivaram/kafka KAFKA
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/3195
KAFKA-5345: Close KafkaClient when streams client is closed
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rajinisivaram/kafka KAFKA
Github user rajinisivaram closed the pull request at:
https://github.com/apache/kafka/pull/3168
---
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 rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/3190
KAFKA-4956: Verify client-side throttle time metrics in quota test
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rajinisivaram/kafka
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/3169
MINOR: Fix doc for producer throttle time metrics
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rajinisivaram/kafka MINOR-producer
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/3168
KAFKA-4956: System test for request quotas
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rajinisivaram/kafka KAFKA-4956
Alternatively
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/3146
MINOR: Cleanup in tests to avoid threads being left behind
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rajinisivaram/kafka MINOR-test
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/3137
KAFKA-5320: Include all request throttling in client throttle metrics
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rajinisivaram/kafka
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/3124
KAFKA-5263: Avoid tight polling loop in consumer with no ready nodes
If all brokers are unavailable, consumers using manual assignment poll in a
tight loop with no channels to poll from
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/3069
KAFKA-4957: Request rate quotas documentation
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rajinisivaram/kafka KAFKA-4957
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/3068
KAFKA-5250: Do fetch down conversion after throttling
Perform down conversion after throttling to avoid retaining messages in
memory during throttling since this could result in OOM. Also
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/3057
KAFKA-5182: Reduce session timeout in request quota test
Reduce session timeouts for join requests to trigger throttling in the
request quota test.
You can merge this pull request into a Git
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/3039
MINOR: Close ZooKeeper clients in tests
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rajinisivaram/kafka MINOR-close-zkclient
Github user rajinisivaram closed the pull request at:
https://github.com/apache/kafka/pull/2985
---
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 rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/3026
KAFKA-5713: Shutdown brokers in tests
Add broker shutdown for `LeaderEpochIntegrationTest`. Move broker shutdown
in other tests to `tearDown` to ensure brokers are shutdown even if tests fail
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/3014
KAFKA-5182: Close txn coordinator threads during broker shutdown
Shutdown delayed delete purgatory thread, transaction marker purgatory
thread and send thread
Github user rajinisivaram closed the pull request at:
https://github.com/apache/kafka/pull/3011
---
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 rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/3011
KAFKA-5173: Close txn coordinator threads during broker shutdown
Shutdown delayed delete purgatory thread, transaction marker purgatory
thread and send thread
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/2985
KAFKA-5173: Log jaas.config if broker fails to start
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rajinisivaram/kafka KAFKA-5173-debug
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/2980
KAFKA-5179: Log connection termination during authentication
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rajinisivaram/kafka KAFKA
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka-site/pull/55
Add Rajini to committers page
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rajinisivaram/kafka-site add-rajini
Alternatively you
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/2879
KAFKA-5094: Replace SCRAM credentials in broker logs with tag hidden
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rajinisivaram/kafka
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/2845
KAFKA-4814: Enable ZK ACLs only when zookeeper.set.acl is set
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rajinisivaram/kafka KAFKA
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/2835
KAFKA-5051: Avoid reverse DNS lookup to obtain hostname for TLS
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rajinisivaram/kafka KAFKA
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/2792
MINOR: Fix potential deadlock in consumer close test
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rajinisivaram/kafka MINOR-closetest
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/2744
KAFKA-4954: Request handler utilization quotas
See KIP-124
(https://cwiki.apache.org/confluence/display/KAFKA/KIP-124+-+Request+rate+quotas)
for details
You can merge this pull request
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/2733
KAFKA-4943: Make /config/users with SCRAM credentials not world-readable
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rajinisivaram
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/2622
KAFKA-4631: Request metadata in consumer if topic/partitions unavailable
If leader node of one more more partitions in a consumer subscription are
temporarily unavailable, request metadata
Github user rajinisivaram closed the pull request at:
https://github.com/apache/kafka/pull/2608
---
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 rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/2608
KAFKA-4779: Request metadata in consumer if partitions unavailable
If leader node of one more more partitions in a consumer subscription are
temporarily unavailable, request metadata refresh
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/2589
KAFKA-4779: Fix security upgrade system test to be non-disruptive
The phase_two security upgrade test verifies upgrading inter-broker and
client protocols to the same value as well
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/2586
KAFKA-4786: Wait for heartbeat thread to terminate in consumer close
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rajinisivaram/kafka
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/2546
KAFKA-4764: Improve diagnostics for SASL auth failures
First step towards improving handling of client SASL authentication
failures.
You can merge this pull request into a Git repository
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/2449
KAFKA-4557: Handle Producer.send correctly in expiry callbacks
When iterating deque for expiring record batches, delay the actual
completion of the batch until iteration is complete since
Github user rajinisivaram closed the pull request at:
https://github.com/apache/kafka/pull/738
---
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
1 - 100 of 196 matches
Mail list logo
