kafka git commit: MINOR: InFlightRequests#isEmpty(node) method corrected.

2017-06-30 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/trunk 647182207 -> 342f34a19 MINOR: InFlightRequests#isEmpty(node) method corrected. - In clearAll method, get operation is removed. - variable name `requestTimeout` changed to `requestTimeoutMs` for clarity Author: Kamal C

kafka git commit: MINOR: Add test brokers to list as they are created to ensure cleanup

2017-07-04 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/trunk cbafc08a5 -> afb91a02a MINOR: Add test brokers to list as they are created to ensure cleanup Author: Rajini Sivaram Reviewers: Apurva Mehta , Ismael Juma Closes #3471

kafka git commit: KAFKA-5402; Avoid creating quota related metrics if quotas not enabled

2017-06-29 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/trunk a05a00e50 -> dc95456f1 KAFKA-5402; Avoid creating quota related metrics if quotas not enabled Author: Rajini Sivaram Reviewers: Jun Rao , Ismael Juma Closes #3303 from

kafka git commit: MINOR: Wait for tasks to terminate to avoid exception in test teardown

2017-07-05 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/trunk ef5867dce -> 48c2160c7 MINOR: Wait for tasks to terminate to avoid exception in test teardown Author: Rajini Sivaram Reviewers: Ismael Juma Closes #3483 from

kafka git commit: KAFKA-4703: Test with two SASL_SSL listeners with different JAAS contexts

2017-05-03 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/trunk 8d7492016 -> a7671c7f3 KAFKA-4703: Test with two SASL_SSL listeners with different JAAS contexts Tests broker with multiple SASL mechanisms with different endpoints for different mechanisms. Each endpoint uses its own JAAS context.

kafka git commit: KAFKA-5182: Reduce rebalance timeouts in request quota test

2017-05-17 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/trunk c36b5b7f6 -> 8c7e66313 KAFKA-5182: Reduce rebalance timeouts in request quota test Reduce rebalance and session timeouts for join requests to trigger throttling in the request quota test. Author: Rajini Sivaram

kafka git commit: KAFKA-5179; Log connection termination during authentication

2017-05-15 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/trunk 46aa88b9c -> 4c75f31a5 KAFKA-5179; Log connection termination during authentication Author: Rajini Sivaram Reviewers: Ismael Juma, Jun Rao Closes #2980 from rajinisivaram/KAFKA-5179 Project:

kafka git commit: MINOR: JoinGroupRequest V0 invalid rebalance timeout

2017-05-11 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/trunk 24a4e6146 -> 27107ee34 MINOR: JoinGroupRequest V0 invalid rebalance timeout A JoinGroupRequest V0 built with the Builder had a rebalance timeout = -1 rather than equal to session timeout as it would have been if coming from the wire and

kafka git commit: KAFKA-5433; Close SimpleAclAuthorizer in test to close ZK client

2017-06-12 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/0.11.0 4508fb2e4 -> 26c6a0715 KAFKA-5433; Close SimpleAclAuthorizer in test to close ZK client Author: Rajini Sivaram Reviewers: Ismael Juma Closes #3304 from rajinisivaram/KAFKA-5433 (cherry

kafka git commit: KAFKA-5433; Close SimpleAclAuthorizer in test to close ZK client

2017-06-12 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/trunk a623d8fe3 -> 46db2c5b9 KAFKA-5433; Close SimpleAclAuthorizer in test to close ZK client Author: Rajini Sivaram Reviewers: Ismael Juma Closes #3304 from rajinisivaram/KAFKA-5433 Project:

kafka git commit: KAFKA-5289: handleStopReplica should not send a second response

2017-05-22 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/0.11.0 ef88ee504 -> e08e76b71 KAFKA-5289: handleStopReplica should not send a second response `shutdownIdleFetcherThreads()` can throw InterruptedException for example. Author: Ismael Juma Reviewers: Rajini Sivaram

kafka git commit: KAFKA-5289: handleStopReplica should not send a second response

2017-05-22 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/trunk d3f1407f7 -> ceb10c533 KAFKA-5289: handleStopReplica should not send a second response `shutdownIdleFetcherThreads()` can throw InterruptedException for example. Author: Ismael Juma Reviewers: Rajini Sivaram

kafka git commit: KAFKA-5294: PlainSaslServerFactory should allow a null Map

2017-05-22 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/0.11.0 6d04e412c -> ef88ee504 KAFKA-5294: PlainSaslServerFactory should allow a null Map If props is null, use POLICY_NOPLAINTEXT default value: false Author: Mickael Maison Reviewers: Ismael Juma ,

kafka git commit: KAFKA-5294: PlainSaslServerFactory should allow a null Map

2017-05-22 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/trunk 495836a4a -> d3f1407f7 KAFKA-5294: PlainSaslServerFactory should allow a null Map If props is null, use POLICY_NOPLAINTEXT default value: false Author: Mickael Maison Reviewers: Ismael Juma ,

kafka git commit: KAFKA-5303, KAFKA-5305: Improve logging when fetches fail in ReplicaFetcherThread

2017-05-22 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/0.11.0 e08e76b71 -> 4c29b1544 KAFKA-5303, KAFKA-5305: Improve logging when fetches fail in ReplicaFetcherThread Author: Ismael Juma Reviewers: Rajini Sivaram Closes #3115 from

kafka git commit: KAFKA-5303, KAFKA-5305: Improve logging when fetches fail in ReplicaFetcherThread

2017-05-22 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/trunk ceb10c533 -> c2ced5fb5 KAFKA-5303, KAFKA-5305: Improve logging when fetches fail in ReplicaFetcherThread Author: Ismael Juma Reviewers: Rajini Sivaram Closes #3115 from

kafka git commit: KAFKA-5263: Avoid tight polling loop in consumer with no ready nodes

2017-05-25 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/0.11.0 22288e805 -> c3f806d02 KAFKA-5263: Avoid tight polling loop in consumer with no ready nodes For consumers with manual partition assignment, await metadata when there are no ready nodes to avoid busy polling. Author: Rajini Sivaram

kafka git commit: KAFKA-5263: Avoid tight polling loop in consumer with no ready nodes

2017-05-25 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/trunk a10990f44 -> 64fc1a7ca KAFKA-5263: Avoid tight polling loop in consumer with no ready nodes For consumers with manual partition assignment, await metadata when there are no ready nodes to avoid busy polling. Author: Rajini Sivaram

kafka git commit: KAFKA-3070: SASL unit tests dont work with IBM JDK

2017-05-18 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/trunk c1fdf575d -> 65edd64ca KAFKA-3070: SASL unit tests dont work with IBM JDK Use IBM Kerberos module for SASL tests if running on IBM JDK Developed with edoardocomar Based on https://github.com/apache/kafka/pull/738 by rajinisivaram Author:

kafka git commit: KAFKA-5345; Close KafkaClient when streams client is closed

2017-06-02 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/0.10.2 e944956a3 -> bac27673f KAFKA-5345; Close KafkaClient when streams client is closed Cherry-pick KAFKA-5345 to 0.10.2 Author: Rajini Sivaram Reviewers: Guozhang Wang , Ismael Juma

kafka git commit: KAFKA-5395; Remove synchronization from AbstractCoordinator.close, remove duplication

2017-06-07 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/0.10.2 bac27673f -> b18ca2543 KAFKA-5395; Remove synchronization from AbstractCoordinator.close, remove duplication Cherry-picked from trunk. Author: Armin Braun Reviewers: Ismael Juma , Jason Gustafson

kafka git commit: KAFKA-5380: Fix transient failure in KafkaConsumerTest, close consumers

2017-06-07 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/trunk b01c83ea9 -> bb914a044 KAFKA-5380: Fix transient failure in KafkaConsumerTest, close consumers 1. Fix ordering of metadata update request for regex subscription to avoid timing issue when heartbeat thread updates metadata 2. Override

kafka git commit: KAFKA-5380: Fix transient failure in KafkaConsumerTest, close consumers

2017-06-07 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/0.11.0 3d0f0caf7 -> 2f5b652a3 KAFKA-5380: Fix transient failure in KafkaConsumerTest, close consumers 1. Fix ordering of metadata update request for regex subscription to avoid timing issue when heartbeat thread updates metadata 2. Override

kafka git commit: KAFKA-5439; Verify that no unexpected threads are left behind in tests

2017-06-13 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/trunk 435e5e196 -> aaca1b478 KAFKA-5439; Verify that no unexpected threads are left behind in tests Author: Rajini Sivaram Reviewers: Ismael Juma Closes #3314 from rajinisivaram/KAFKA-5439

kafka git commit: MINOR: Generate deprecated warning for static default quota config

2017-06-13 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/trunk aaca1b478 -> 136b03868 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 before the property is

kafka git commit: MINOR: Clean up in DeleteConsumerGroupTest even if test fails

2017-06-13 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/trunk 85b7c855b -> 5c9557857 MINOR: Clean up in DeleteConsumerGroupTest even if test fails Author: Rajini Sivaram Reviewers: Ismael Juma Closes #3317 from

kafka git commit: MINOR: Clean up in DeleteConsumerGroupTest even if test fails

2017-06-13 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/0.11.0 687a61bac -> 24676a17b MINOR: Clean up in DeleteConsumerGroupTest even if test fails Author: Rajini Sivaram Reviewers: Ismael Juma Closes #3317 from

kafka git commit: MINOR: Generate deprecated warning for static default quota config

2017-06-13 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/0.11.0 2b34e587e -> 466463241 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 before the property is

kafka git commit: KAFKA-5320: Include all request throttling in client throttle metrics

2017-05-25 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/0.11.0 a7bd4b3aa -> 7dde914aa KAFKA-5320: Include all request throttling in client throttle metrics Author: Rajini Sivaram Reviewers: Jun Rao , Ismael Juma Closes #3137 from

kafka git commit: KAFKA-5320: Include all request throttling in client throttle metrics

2017-05-25 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/trunk 20e200878 -> 73ca0d215 KAFKA-5320: Include all request throttling in client throttle metrics Author: Rajini Sivaram Reviewers: Jun Rao , Ismael Juma Closes #3137 from

kafka git commit: KAFKA-4956: Verify client-side throttle time metrics in quota test

2017-06-01 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/trunk e0150a25e -> 640082776 KAFKA-4956: Verify client-side throttle time metrics in quota test Author: Rajini Sivaram Reviewers: Jun Rao Closes #3190 from rajinisivaram/KAFKA-4956-unittest

kafka git commit: KAFKA-4956: Verify client-side throttle time metrics in quota test

2017-06-01 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/0.11.0 13d189df6 -> 44e036702 KAFKA-4956: Verify client-side throttle time metrics in quota test Author: Rajini Sivaram Reviewers: Jun Rao Closes #3190 from rajinisivaram/KAFKA-4956-unittest

kafka git commit: KAFKA-5051; Avoid reverse DNS lookup to obtain hostname for TLS

2017-06-06 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/0.11.0 8f9ee0ee4 -> 1d943a765 KAFKA-5051; Avoid reverse DNS lookup to obtain hostname for TLS Author: Rajini Sivaram Reviewers: Jun Rao , Ismael Juma Closes #2835 from

kafka git commit: KAFKA-5051; Avoid reverse DNS lookup to obtain hostname for TLS

2017-06-06 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/trunk 4b37918ef -> 17b2bde4b KAFKA-5051; Avoid reverse DNS lookup to obtain hostname for TLS Author: Rajini Sivaram Reviewers: Jun Rao , Ismael Juma Closes #2835 from

kafka git commit: KAFKA-4948; Wait for offset commit in test to fix transient failure

2017-06-06 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/trunk cb78ba129 -> 3de683993 KAFKA-4948; Wait for offset commit in test to fix transient failure `DescribeConsumerGroupTest#testDescribeExistingGroupWithNoMembersWithNewConsumer` shuts down the consumer executor thread and then checks that the

kafka git commit: KAFKA-4948; Wait for offset commit in test to fix transient failure

2017-06-06 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/0.11.0 9419204c2 -> c39fea37e KAFKA-4948; Wait for offset commit in test to fix transient failure `DescribeConsumerGroupTest#testDescribeExistingGroupWithNoMembersWithNewConsumer` shuts down the consumer executor thread and then checks that the

[1/2] kafka git commit: KAFKA-5783; Add KafkaPrincipalBuilder with support for SASL (KIP-189)

2017-09-14 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/trunk f7b1add68 -> 3b5d88feb http://git-wip-us.apache.org/repos/asf/kafka/blob/3b5d88fe/clients/src/main/java/org/apache/kafka/common/security/authenticator/SaslServerCallbackHandler.java

[2/2] kafka git commit: KAFKA-5783; Add KafkaPrincipalBuilder with support for SASL (KIP-189)

2017-09-14 Thread rsivaram
KAFKA-5783; Add KafkaPrincipalBuilder with support for SASL (KIP-189) Author: Jason Gustafson Reviewers: Ismael Juma , Rajini Sivaram , Manikumar Reddy Closes #3795 from hachikuji/KAFKA-5783

[1/2] kafka git commit: KAFKA-4764; Wrap SASL tokens in Kafka headers to improve diagnostics (KIP-152)

2017-09-15 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/trunk 985cc534a -> 8fca43222 http://git-wip-us.apache.org/repos/asf/kafka/blob/8fca4322/clients/src/test/java/org/apache/kafka/common/security/authenticator/SaslAuthenticatorTest.java

kafka git commit: MINOR: Update powermock and enable its tests when running with Java 9

2017-09-18 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/trunk a339a387e -> a3f068e22 MINOR: Update powermock and enable its tests when running with Java 9 Also: 1. Fix WorkerTest to use the correct `Mock` annotations. `org.easymock.Mock` is not supported by PowerMock 2.x. 2. Rename `powermock` to

kafka git commit: KAFKA-5735; KIP-190: Handle client-ids consistently

2017-09-21 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/trunk afaaea809 -> c8c6ab632 KAFKA-5735; KIP-190: Handle client-ids consistently Developed with edoardocomar Author: Mickael Maison Reviewers: Edoardo Comar , Rajini Sivaram

kafka git commit: KAFKA-5854; Handle SASL authentication failures as non-retriable exceptions in clients

2017-09-20 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/trunk c2af13ed0 -> 69d2a1771 KAFKA-5854; Handle SASL authentication failures as non-retriable exceptions in clients This PR implements the client-side of KIP-152, by modifying `KafkaConsumer`, `KafkaProducer`, and `ConsumerGroupCommand` to

kafka git commit: KAFKA-4764; Upgrade notes for authentication failure handling (KIP-152)

2017-10-04 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/trunk 28aaba281 -> a202da742 KAFKA-4764; Upgrade notes for authentication failure handling (KIP-152) Author: Rajini Sivaram Reviewers: Ismael Juma Closes #4013 from

kafka git commit: KAFKA-5738; Upgrade note for cumulative count metric (KIP-187)

2017-10-04 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/trunk a202da742 -> c4b8a7eab KAFKA-5738; Upgrade note for cumulative count metric (KIP-187) Author: Rajini Sivaram Reviewers: Ismael Juma Closes #4014 from rajinisivaram/MINOR-upgrade-KIP-187

kafka git commit: KAFKA-6004; Allow authentication providers to override error message

2017-10-04 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/trunk 5afeddaa9 -> 9949e1ed1 KAFKA-6004; Allow authentication providers to override error message Author: Rajini Sivaram Reviewers: Ismael Juma Closes #4015 from

kafka git commit: KAFKA-6012; Close request metrics only after closing request handlers

2017-10-05 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/1.0 dc907d9b7 -> 6c01d68c9 KAFKA-6012; Close request metrics only after closing request handlers Author: Rajini Sivaram Reviewers: Ismael Juma Closes #4024 from

kafka git commit: KAFKA-5777; Add ducktape integration for Trogdor

2017-09-07 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/trunk 329d5fa64 -> 4065ffb3e KAFKA-5777; Add ducktape integration for Trogdor Author: Colin P. Mccabe Reviewers: Rajini Sivaram Closes #3726 from cmccabe/KAFKA-5777 Project:

kafka git commit: KAFKA-5837; Set defaults for ReassignPartitionsCommand correctly

2017-09-05 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/trunk 81e789ae3 -> 5d6996619 KAFKA-5837; Set defaults for ReassignPartitionsCommand correctly Author: Rajini Sivaram Reviewers: Dong Lin Closes #3792 from rajinisivaram/KAFKA-5837 Project:

kafka git commit: MINOR: Fix transient failure in SelectorTest.testCloseConnectionInClosingState

2017-09-10 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/trunk ae4100f82 -> 3728f4cd9 MINOR: Fix transient failure in SelectorTest.testCloseConnectionInClosingState `SelectorTest.testCloseConnectionInClosingState` creates a channel with some staging receives and moves time forward to expire the

kafka git commit: KAFKA-5872; Fix transient failure in SslSelectorTest.testMuteOnOOM

2017-09-12 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/trunk 8bd2a68b5 -> 9ed8bf273 KAFKA-5872; Fix transient failure in SslSelectorTest.testMuteOnOOM Author: Rajini Sivaram Reviewers: Ismael Juma Closes #3836 from

kafka git commit: KAFKA-5746; Fix conversion count computed in `downConvert`

2017-09-29 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/trunk a86873be5 -> 177dd7f21 KAFKA-5746; Fix conversion count computed in `downConvert` It should be the number of records instead of the number of batches. A few additional clean-ups: - Minor renames - Removed unused variable - Some test fixes

kafka git commit: MINOR: Fix transient failure in SocketServerTest.testConnectionIdReuse

2017-08-24 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/trunk 71417552c -> e6164ec61 MINOR: Fix transient failure in SocketServerTest.testConnectionIdReuse Two requests sent together may not always trigger a staged receive since the requests may not be received in a single poll and the channel is

[2/3] kafka git commit: KAFKA-5776; Add the Trogdor fault injection daemon

2017-08-25 Thread rsivaram
http://git-wip-us.apache.org/repos/asf/kafka/blob/0772fde5/tools/src/main/java/org/apache/kafka/trogdor/fault/Fault.java -- diff --git a/tools/src/main/java/org/apache/kafka/trogdor/fault/Fault.java

[1/3] kafka git commit: KAFKA-5776; Add the Trogdor fault injection daemon

2017-08-25 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/trunk 607c3c21f -> 0772fde56 http://git-wip-us.apache.org/repos/asf/kafka/blob/0772fde5/tools/src/test/java/org/apache/kafka/trogdor/common/MiniTrogdorCluster.java -- diff --git

[3/3] kafka git commit: KAFKA-5776; Add the Trogdor fault injection daemon

2017-08-25 Thread rsivaram
KAFKA-5776; Add the Trogdor fault injection daemon Author: Colin P. Mccabe Reviewers: Ismael Juma , Rajini Sivaram Closes #3699 from cmccabe/trogdor-review Project: http://git-wip-us.apache.org/repos/asf/kafka/repo

kafka git commit: MINOR: Test SASL authorization id

2017-08-31 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/trunk 9ebc303bb -> 47c275349 MINOR: Test SASL authorization id Author: Rajini Sivaram Reviewers: Ismael Juma Closes #3766 from rajinisivaram/MINOR-sasl Project:

kafka git commit: MINOR: Test SASL authorization id

2017-08-31 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/0.11.0 0cffb6237 -> 9f3468645 MINOR: Test SASL authorization id Author: Rajini Sivaram Reviewers: Ismael Juma Closes #3766 from rajinisivaram/MINOR-sasl (cherry picked from commit

kafka git commit: MINOR: Test SASL authorization id

2017-08-31 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/0.10.2 565455eae -> 0b4daa4bf MINOR: Test SASL authorization id Author: Rajini Sivaram Reviewers: Ismael Juma Closes #3766 from rajinisivaram/MINOR-sasl (cherry picked from commit

kafka git commit: MINOR: Fix unit test failures from last commit, cherry-pick fix for SASL principal

2017-08-31 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/0.10.2 0b4daa4bf -> c9168e10f MINOR: Fix unit test failures from last commit, cherry-pick fix for SASL principal This fixes PlainSaslServerTest from the last commit which uses a class not present in 0.10.2. Also cherry-picked commit 9934d28 to

kafka git commit: KAFKA-6010; Relax record conversion time test to avoid build failure

2017-10-04 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/trunk 06738b41b -> 51c652c40 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. Since default value is -1, the test

kafka git commit: MINOR: Push JMX metric name mangling into the JmxReporter (KIP-190 follow up)

2017-10-11 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/trunk 54ed3435b -> 7d6ca52a2 MINOR: Push JMX metric name mangling into the JmxReporter (KIP-190 follow up) Author: Ewen Cheslack-Postava Reviewers: Rajini Sivaram , Ismael Juma

kafka git commit: MINOR: Push JMX metric name mangling into the JmxReporter (KIP-190 follow up)

2017-10-11 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/1.0 2cf059f33 -> 531dfd726 MINOR: Push JMX metric name mangling into the JmxReporter (KIP-190 follow up) Author: Ewen Cheslack-Postava Reviewers: Rajini Sivaram , Ismael Juma

kafka git commit: KAFKA-6255; Add ProduceBench to Trogdor

2017-11-28 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/trunk 1a1d923f2 -> 58877a0de KAFKA-6255; Add ProduceBench to Trogdor Author: Colin P. Mccabe Reviewers: Rajini Sivaram Closes #4245 from cmccabe/KAFKA-6255 Project:

[20/51] [partial] kafka-site git commit: Update site for 0.11.0.2 release

2017-11-17 Thread rsivaram
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ae86b7d5/0110/javadoc/org/apache/kafka/common/errors/NotCoordinatorForGroupException.html -- diff --git

[17/51] [partial] kafka-site git commit: Update site for 0.11.0.2 release

2017-11-17 Thread rsivaram
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ae86b7d5/0110/javadoc/org/apache/kafka/common/errors/UnknownMemberIdException.html -- diff --git a/0110/javadoc/org/apache/kafka/common/errors/UnknownMemberIdException.html

[01/51] [partial] kafka-site git commit: Update site for 0.11.0.2 release

2017-11-17 Thread rsivaram
Repository: kafka-site Updated Branches: refs/heads/asf-site 240ddda6e -> ae86b7d5d http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ae86b7d5/0110/javadoc/org/apache/kafka/streams/StreamsMetrics.html -- diff --git

[24/51] [partial] kafka-site git commit: Update site for 0.11.0.2 release

2017-11-17 Thread rsivaram
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ae86b7d5/0110/javadoc/org/apache/kafka/common/errors/CorruptRecordException.html -- diff --git a/0110/javadoc/org/apache/kafka/common/errors/CorruptRecordException.html

[27/51] [partial] kafka-site git commit: Update site for 0.11.0.2 release

2017-11-17 Thread rsivaram
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ae86b7d5/0110/javadoc/org/apache/kafka/common/config/SslConfigs.html -- diff --git a/0110/javadoc/org/apache/kafka/common/config/SslConfigs.html

[25/51] [partial] kafka-site git commit: Update site for 0.11.0.2 release

2017-11-17 Thread rsivaram
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ae86b7d5/0110/javadoc/org/apache/kafka/common/errors/AuthenticationException.html -- diff --git a/0110/javadoc/org/apache/kafka/common/errors/AuthenticationException.html

[30/51] [partial] kafka-site git commit: Update site for 0.11.0.2 release

2017-11-17 Thread rsivaram
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ae86b7d5/0110/javadoc/org/apache/kafka/common/config/ConfigDef.ValidString.html -- diff --git a/0110/javadoc/org/apache/kafka/common/config/ConfigDef.ValidString.html

[35/51] [partial] kafka-site git commit: Update site for 0.11.0.2 release

2017-11-17 Thread rsivaram
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ae86b7d5/0110/javadoc/org/apache/kafka/clients/producer/ProducerRecord.html -- diff --git a/0110/javadoc/org/apache/kafka/clients/producer/ProducerRecord.html

[51/51] [partial] kafka-site git commit: Update site for 0.11.0.2 release

2017-11-17 Thread rsivaram
Update site for 0.11.0.2 release Also includes: KAFKA-6222: Use www.apache.org/dist/kafka for sigs and hashes KAFKA-6223: Use archive server for old releases Project: http://git-wip-us.apache.org/repos/asf/kafka-site/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka-site/commit/ae86b7d5

[08/51] [partial] kafka-site git commit: Update site for 0.11.0.2 release

2017-11-17 Thread rsivaram
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ae86b7d5/0110/javadoc/org/apache/kafka/connect/data/Time.html -- diff --git a/0110/javadoc/org/apache/kafka/connect/data/Time.html

[04/51] [partial] kafka-site git commit: Update site for 0.11.0.2 release

2017-11-17 Thread rsivaram
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ae86b7d5/0110/javadoc/org/apache/kafka/server/policy/CreateTopicPolicy.RequestMetadata.html -- diff --git

[28/51] [partial] kafka-site git commit: Update site for 0.11.0.2 release

2017-11-17 Thread rsivaram
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ae86b7d5/0110/javadoc/org/apache/kafka/common/config/ConfigException.html -- diff --git a/0110/javadoc/org/apache/kafka/common/config/ConfigException.html

[46/51] [partial] kafka-site git commit: Update site for 0.11.0.2 release

2017-11-17 Thread rsivaram
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ae86b7d5/0110/javadoc/org/apache/kafka/clients/admin/DescribeClusterOptions.html -- diff --git a/0110/javadoc/org/apache/kafka/clients/admin/DescribeClusterOptions.html

[34/51] [partial] kafka-site git commit: Update site for 0.11.0.2 release

2017-11-17 Thread rsivaram
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ae86b7d5/0110/javadoc/org/apache/kafka/common/Configurable.html -- diff --git a/0110/javadoc/org/apache/kafka/common/Configurable.html

[16/51] [partial] kafka-site git commit: Update site for 0.11.0.2 release

2017-11-17 Thread rsivaram
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ae86b7d5/0110/javadoc/org/apache/kafka/common/header/Headers.html -- diff --git a/0110/javadoc/org/apache/kafka/common/header/Headers.html

[12/51] [partial] kafka-site git commit: Update site for 0.11.0.2 release

2017-11-17 Thread rsivaram
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ae86b7d5/0110/javadoc/org/apache/kafka/common/serialization/Serdes.ShortSerde.html -- diff --git a/0110/javadoc/org/apache/kafka/common/serialization/Serdes.ShortSerde.html

[50/51] [partial] kafka-site git commit: Update site for 0.11.0.2 release

2017-11-17 Thread rsivaram
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ae86b7d5/0110/javadoc/constant-values.html -- diff --git a/0110/javadoc/constant-values.html b/0110/javadoc/constant-values.html index bcf9123..5db3bcf 100644 ---

[39/51] [partial] kafka-site git commit: Update site for 0.11.0.2 release

2017-11-17 Thread rsivaram
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ae86b7d5/0110/javadoc/org/apache/kafka/clients/consumer/OffsetAndMetadata.html -- diff --git a/0110/javadoc/org/apache/kafka/clients/consumer/OffsetAndMetadata.html

[05/51] [partial] kafka-site git commit: Update site for 0.11.0.2 release

2017-11-17 Thread rsivaram
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ae86b7d5/0110/javadoc/org/apache/kafka/connect/source/SourceTask.html -- diff --git a/0110/javadoc/org/apache/kafka/connect/source/SourceTask.html

[10/51] [partial] kafka-site git commit: Update site for 0.11.0.2 release

2017-11-17 Thread rsivaram
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ae86b7d5/0110/javadoc/org/apache/kafka/connect/data/ConnectSchema.html -- diff --git a/0110/javadoc/org/apache/kafka/connect/data/ConnectSchema.html

[11/51] [partial] kafka-site git commit: Update site for 0.11.0.2 release

2017-11-17 Thread rsivaram
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ae86b7d5/0110/javadoc/org/apache/kafka/common/serialization/StringSerializer.html -- diff --git a/0110/javadoc/org/apache/kafka/common/serialization/StringSerializer.html

[02/51] [partial] kafka-site git commit: Update site for 0.11.0.2 release

2017-11-17 Thread rsivaram
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ae86b7d5/0110/javadoc/org/apache/kafka/streams/StreamsConfig.html -- diff --git a/0110/javadoc/org/apache/kafka/streams/StreamsConfig.html

[19/51] [partial] kafka-site git commit: Update site for 0.11.0.2 release

2017-11-17 Thread rsivaram
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ae86b7d5/0110/javadoc/org/apache/kafka/common/errors/PolicyViolationException.html -- diff --git a/0110/javadoc/org/apache/kafka/common/errors/PolicyViolationException.html

[31/51] [partial] kafka-site git commit: Update site for 0.11.0.2 release

2017-11-17 Thread rsivaram
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ae86b7d5/0110/javadoc/org/apache/kafka/common/config/Config.html -- diff --git a/0110/javadoc/org/apache/kafka/common/config/Config.html

[43/51] [partial] kafka-site git commit: Update site for 0.11.0.2 release

2017-11-17 Thread rsivaram
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ae86b7d5/0110/javadoc/org/apache/kafka/clients/consumer/ConsumerConfig.html -- diff --git a/0110/javadoc/org/apache/kafka/clients/consumer/ConsumerConfig.html

[06/51] [partial] kafka-site git commit: Update site for 0.11.0.2 release

2017-11-17 Thread rsivaram
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ae86b7d5/0110/javadoc/org/apache/kafka/connect/sink/SinkTask.html -- diff --git a/0110/javadoc/org/apache/kafka/connect/sink/SinkTask.html

[37/51] [partial] kafka-site git commit: Update site for 0.11.0.2 release

2017-11-17 Thread rsivaram
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ae86b7d5/0110/javadoc/org/apache/kafka/clients/producer/MockProducer.html -- diff --git a/0110/javadoc/org/apache/kafka/clients/producer/MockProducer.html

[32/51] [partial] kafka-site git commit: Update site for 0.11.0.2 release

2017-11-17 Thread rsivaram
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ae86b7d5/0110/javadoc/org/apache/kafka/common/acl/AclPermissionType.html -- diff --git a/0110/javadoc/org/apache/kafka/common/acl/AclPermissionType.html

[42/51] [partial] kafka-site git commit: Update site for 0.11.0.2 release

2017-11-17 Thread rsivaram
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ae86b7d5/0110/javadoc/org/apache/kafka/clients/consumer/ConsumerRecord.html -- diff --git a/0110/javadoc/org/apache/kafka/clients/consumer/ConsumerRecord.html

[33/51] [partial] kafka-site git commit: Update site for 0.11.0.2 release

2017-11-17 Thread rsivaram
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ae86b7d5/0110/javadoc/org/apache/kafka/common/PartitionInfo.html -- diff --git a/0110/javadoc/org/apache/kafka/common/PartitionInfo.html

[15/51] [partial] kafka-site git commit: Update site for 0.11.0.2 release

2017-11-17 Thread rsivaram
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ae86b7d5/0110/javadoc/org/apache/kafka/common/serialization/ByteBufferDeserializer.html -- diff --git

[18/51] [partial] kafka-site git commit: Update site for 0.11.0.2 release

2017-11-17 Thread rsivaram
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ae86b7d5/0110/javadoc/org/apache/kafka/common/errors/SecurityDisabledException.html -- diff --git a/0110/javadoc/org/apache/kafka/common/errors/SecurityDisabledException.html

[41/51] [partial] kafka-site git commit: Update site for 0.11.0.2 release

2017-11-17 Thread rsivaram
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ae86b7d5/0110/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html -- diff --git a/0110/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html

[29/51] [partial] kafka-site git commit: Update site for 0.11.0.2 release

2017-11-17 Thread rsivaram
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ae86b7d5/0110/javadoc/org/apache/kafka/common/config/ConfigDef.html -- diff --git a/0110/javadoc/org/apache/kafka/common/config/ConfigDef.html

[21/51] [partial] kafka-site git commit: Update site for 0.11.0.2 release

2017-11-17 Thread rsivaram
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ae86b7d5/0110/javadoc/org/apache/kafka/common/errors/InvalidTimestampException.html -- diff --git a/0110/javadoc/org/apache/kafka/common/errors/InvalidTimestampException.html

[26/51] [partial] kafka-site git commit: Update site for 0.11.0.2 release

2017-11-17 Thread rsivaram
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ae86b7d5/0110/javadoc/org/apache/kafka/common/config/TopicConfig.html -- diff --git a/0110/javadoc/org/apache/kafka/common/config/TopicConfig.html

[47/51] [partial] kafka-site git commit: Update site for 0.11.0.2 release

2017-11-17 Thread rsivaram
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ae86b7d5/0110/javadoc/org/apache/kafka/clients/admin/CreateAclsResult.html -- diff --git a/0110/javadoc/org/apache/kafka/clients/admin/CreateAclsResult.html

  1   2   3   4   5   6   7   8   >