kafka git commit: KAFKA-2711; SaslClientAuthenticator no longer needs KerberosNameParser in constructor

Repository: kafka Updated Branches: refs/heads/trunk 622730905 -> d9ae33d4c KAFKA-2711; SaslClientAuthenticator no longer needs KerberosNameParser in constructor Also refactor `KerberosNameParser` and `KerberosName` to make the code clearer and easier to use when `shortName` is not needed.

kafka git commit: KAFKA-2680; Use IBM ConfigFile class to load jaas config if IBM JDK

Repository: kafka Updated Branches: refs/heads/trunk b94435699 -> 9d8dd9f10 KAFKA-2680; Use IBM ConfigFile class to load jaas config if IBM JDK Use IBM ConfigFile class with IBM JDK since JavaLoginConfig provided by SUN provider is not included with IBM JDK. Author: Rajini Sivaram

kafka git commit: KAFKA-2719; Use wildcard classpath for dependant-libs

Repository: kafka Updated Branches: refs/heads/trunk 7c3347527 -> 694e03c35 KAFKA-2719; Use wildcard classpath for dependant-libs PR switches to wildcard classpath for dependant libs to restrict the length of classpath, thereby reducing command line length. Author: Rajini Sivaram

[2/5] kafka git commit: KAFKA-2639: Refactoring of ZkUtils

http://git-wip-us.apache.org/repos/asf/kafka/blob/ce306ba4/core/src/test/scala/other/kafka/TestOffsetManager.scala -- diff --git a/core/src/test/scala/other/kafka/TestOffsetManager.scala

[3/5] kafka git commit: KAFKA-2639: Refactoring of ZkUtils

http://git-wip-us.apache.org/repos/asf/kafka/blob/ce306ba4/core/src/main/scala/kafka/server/ZookeeperLeaderElector.scala -- diff --git a/core/src/main/scala/kafka/server/ZookeeperLeaderElector.scala

[4/5] kafka git commit: KAFKA-2639: Refactoring of ZkUtils

http://git-wip-us.apache.org/repos/asf/kafka/blob/ce306ba4/core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala -- diff --git a/core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala

kafka git commit: KAFKA-2477: Fix a race condition between log append and fetch that causes OffsetOutOfRangeException.

Repository: kafka Updated Branches: refs/heads/trunk 693d4ca1a -> f1110c3fb KAFKA-2477: Fix a race condition between log append and fetch that causes OffsetOutOfRangeException. Tried two fixes. I prefer the second approach because it saves an additional offset search. Author: Jiangjie Qin

kafka git commit: Kafka-2587: Only notification handler will update the cache and all verifications will use waitUntilTrue.

Repository: kafka Updated Branches: refs/heads/trunk 118912e76 -> 2254f2bfa Kafka-2587: Only notification handler will update the cache and all verifications will use waitUntilTrue. Author: Parth Brahmbhatt Reviewers: Ismael Juma , Jun Rao

kafka git commit: MINOR: Reduce logging level for controller connection failures from `error` to `warn`

Repository: kafka Updated Branches: refs/heads/trunk 241b9ab58 -> 964114a8a MINOR: Reduce logging level for controller connection failures from `error` to `warn` Before we switched from `BlockingChannel` to `NetworkClient`, we were always reporting a successful connection due to the fact

kafka git commit: KAFKA-2656; Remove hardcoded default key and truststores

Repository: kafka Updated Branches: refs/heads/trunk 964114a8a -> 674543525 KAFKA-2656; Remove hardcoded default key and truststores Removed default hardcoded keystore and truststore in /tmp so that default JVM keystore/truststore may be used when keystore/truststore is not specified in

[4/4] kafka git commit: KAFKA-1686; Implement SASL/Kerberos

KAFKA-1686; Implement SASL/Kerberos This PR implements SASL/Kerberos which was originally submitted by harshach as https://github.com/apache/kafka/pull/191. I've been submitting PRs to Harsha's branch with fixes and improvements and he has integrated all, but the most recent one. I'm creating

[3/4] kafka git commit: KAFKA-1686; Implement SASL/Kerberos

http://git-wip-us.apache.org/repos/asf/kafka/blob/403158b5/clients/src/main/java/org/apache/kafka/common/security/kerberos/KerberosRule.java -- diff --git

[2/4] kafka git commit: KAFKA-1686; Implement SASL/Kerberos

http://git-wip-us.apache.org/repos/asf/kafka/blob/403158b5/core/src/test/scala/integration/kafka/api/BaseConsumerTest.scala -- diff --git a/core/src/test/scala/integration/kafka/api/BaseConsumerTest.scala

kafka git commit: MINOR: Use the correct processor id in the processor thread name

Repository: kafka Updated Branches: refs/heads/trunk 1265d7cb7 -> bd98a99c1 MINOR: Use the correct processor id in the processor thread name This restores the behaviour before 1265d7cb7. Author: Ismael Juma Reviewers: Jun Rao Closes #294 from

kafka git commit: KAFKA-2614; No more clients can connect after `TooManyConnectionsException` threshold (max.connections.per.ip) is reached

Repository: kafka Updated Branches: refs/heads/trunk c67ca6588 -> 1265d7cb7 KAFKA-2614; No more clients can connect after `TooManyConnectionsException` threshold (max.connections.per.ip) is reached * Call `ConnectionQuotas.decr` when calling `Selector.close` and when disconnections happen.

kafka git commit: KAFKA-2534: Fixes and unit tests for SSLTransportLayer buffer overflow

Repository: kafka Updated Branches: refs/heads/trunk 02e103b75 -> 2047a9afe KAFKA-2534: Fixes and unit tests for SSLTransportLayer buffer overflow Unit tests which mock buffer overflow and underflow in the SSL transport layer and fixes for the couple of issues in buffer overflow handling

kafka git commit: KAFKA-2746; Add support for using ConsumerGroupCommand on secure install

Repository: kafka Updated Branches: refs/heads/trunk 52d5e8839 -> ffc0965d3 KAFKA-2746; Add support for using ConsumerGroupCommand on secure install Author: Ashish Singh Reviewers: Ismael Juma , Jason Gustafson , Jun Rao

kafka git commit: KAFKA-2746; Add support for using ConsumerGroupCommand on secure install

Repository: kafka Updated Branches: refs/heads/0.9.0 154073026 -> 723c6f2de KAFKA-2746; Add support for using ConsumerGroupCommand on secure install Author: Ashish Singh Reviewers: Ismael Juma , Jason Gustafson , Jun Rao

kafka git commit: KAFKA-2800; Update outdated dependencies

Repository: kafka Updated Branches: refs/heads/trunk 17c6f3312 -> 8f6ffe1c2 KAFKA-2800; Update outdated dependencies Changes: * org.scala-lang:scala-library [2.10.5 -> 2.10.6] * Scala 2.10.6 resolves a license incompatibility in scala.util.Sorting * Otherwise identical to Scala 2.10.5 *

[3/3] kafka-site git commit: upload latest 0.9.0 docs

upload latest 0.9.0 docs Project: http://git-wip-us.apache.org/repos/asf/kafka-site/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka-site/commit/24d8d665 Tree: http://git-wip-us.apache.org/repos/asf/kafka-site/tree/24d8d665 Diff:

[2/3] kafka-site git commit: upload latest 0.9.0 docs

http://git-wip-us.apache.org/repos/asf/kafka-site/blob/24d8d665/090/introduction.html -- diff --git a/090/introduction.html b/090/introduction.html index 7e0b150..e5b2e78 100644 --- a/090/introduction.html +++

[1/3] kafka-site git commit: upload latest 0.9.0 docs

Repository: kafka-site Updated Branches: refs/heads/asf-site fdd6433bd -> 24d8d665e http://git-wip-us.apache.org/repos/asf/kafka-site/blob/24d8d665/090/javadoc/org/apache/kafka/common/serialization/ByteArrayDeserializer.html

kafka git commit: KAFKA-2841; safe group metadata cache loading/unloading

Repository: kafka Updated Branches: refs/heads/trunk 06d2c7816 -> dbdec927b KAFKA-2841; safe group metadata cache loading/unloading Author: Jason Gustafson Reviewers: Guozhang Wang , Jun Rao Closes #530 from hachikuji/KAFKA-2841

kafka git commit: KAFKA-2841; safe group metadata cache loading/unloading

Repository: kafka Updated Branches: refs/heads/0.9.0 9f2f9fb8f -> a2bc9501d KAFKA-2841; safe group metadata cache loading/unloading Author: Jason Gustafson Reviewers: Guozhang Wang , Jun Rao Closes #530 from hachikuji/KAFKA-2841

kafka git commit: KAFKA-2852; Updating the Authorizer CLI to use a consistent way to specify a list of values for a config options.

Repository: kafka Updated Branches: refs/heads/0.9.0 723c6f2de -> fda91fcc9 KAFKA-2852; Updating the Authorizer CLI to use a consistent way to specify a list of values for a config options. …ecify a list of values for a config options. Author: Parth Brahmbhatt

kafka git commit: MINOR: fix shutdownHook in ConsoleConsumer

Repository: kafka Updated Branches: refs/heads/trunk dacd21ec4 -> 36b1c1dae MINOR: fix shutdownHook in ConsoleConsumer Author: Confluent Reviewers: Jun Rao Closes #548 from guozhangwang/HFConsoleConsumer Project:

kafka git commit: MINOR: Introduce `producer.config` property to `ConsoleProducer`

Repository: kafka Updated Branches: refs/heads/trunk 36b1c1dae -> 06d2c7816 MINOR: Introduce `producer.config` property to `ConsoleProducer` This makes it easier to pass security properties in the same way to `ConsoleConsumer` and `ConsoleProducer`. Author: Ismael Juma

kafka git commit: MINOR: Introduce `producer.config` property to `ConsoleProducer`

Repository: kafka Updated Branches: refs/heads/0.9.0 45d6fb717 -> 9f2f9fb8f MINOR: Introduce `producer.config` property to `ConsoleProducer` This makes it easier to pass security properties in the same way to `ConsoleConsumer` and `ConsoleProducer`. Author: Ismael Juma

kafka git commit: trivial fix to 0.9.0 docs

Repository: kafka Updated Branches: refs/heads/0.9.0 a2bc9501d -> fe855f982 trivial fix to 0.9.0 docs Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/fe855f98 Tree:

kafka-site git commit: trivial 0.9.0 doc fixes

Repository: kafka-site Updated Branches: refs/heads/asf-site 24d8d665e -> dbcd9fd14 trivial 0.9.0 doc fixes Project: http://git-wip-us.apache.org/repos/asf/kafka-site/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka-site/commit/dbcd9fd1 Tree:

kafka git commit: KAFKA-2624; Change log message position

Repository: kafka Updated Branches: refs/heads/trunk f6d369b70 -> 356544cab KAFKA-2624; Change log message position Log warning message before truncating log in order to display right offset value for the truncated log. Author: Francois Visconte Reviewers: Dong Lin

kafka git commit: KAFKA-2624; Change log message position

Repository: kafka Updated Branches: refs/heads/0.9.0 e96b7239f -> 2261763bc KAFKA-2624; Change log message position Log warning message before truncating log in order to display right offset value for the truncated log. Author: Francois Visconte Reviewers: Dong Lin

Git Push Summary

Repository: kafka Updated Tags: refs/tags/0.8.2.2 [created] 7d004e951

Git Push Summary

Repository: kafka Updated Tags: refs/tags/0.8.2.2 [deleted] 7d004e951

kafka git commit: change build version to 0.8.2.2

Repository: kafka Updated Branches: refs/heads/0.8.2 fbfdc195d -> f090e119e change build version to 0.8.2.2 Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/f090e119 Tree:

[3/3] kafka git commit: KAFKA-2411; remove usage of blocking channel

KAFKA-2411; remove usage of blocking channel Author: Ismael Juma Reviewers: Jun Rao , Gwen Shapira Closes #151 from ijuma/kafka-2411-remove-usage-of-blocking-channel Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit:

[2/3] kafka git commit: KAFKA-2411; remove usage of blocking channel

http://git-wip-us.apache.org/repos/asf/kafka/blob/d02ca36c/clients/src/main/java/org/apache/kafka/common/requests/UpdateMetadataRequest.java -- diff --git

[2/2] kafka git commit: KAFKA-2440; Use `NetworkClient` instead of `SimpleConsumer` to fetch data from replica

KAFKA-2440; Use `NetworkClient` instead of `SimpleConsumer` to fetch data from replica Author: Ismael Juma Reviewers: Aditya Auradkar , Jun Rao Closes #194 from ijuma/kafka-2440-use-network-client-in-fetcher Project:

[1/2] kafka git commit: KAFKA-2440; Use `NetworkClient` instead of `SimpleConsumer` to fetch data from replica

Repository: kafka Updated Branches: refs/heads/trunk 6c1957d00 -> 65bf3afe8 http://git-wip-us.apache.org/repos/asf/kafka/blob/65bf3afe/core/src/test/scala/unit/kafka/integration/BaseTopicMetadataTest.scala -- diff --git

kafka git commit: KAFKA-2514: change default JVM options in kafka-run-class.sh.

Repository: kafka Updated Branches: refs/heads/trunk f540f4a91 -> c7bc5366d KAFKA-2514: change default JVM options in kafka-run-class.sh. GC is set to G1 collector. Author: Manikumar reddy O Reviewers: Ismael Juma , Jun Rao

kafka git commit: KAFKA-2586; Enable SSL for inter-broker communication when SSL is enabled in tests

Repository: kafka Updated Branches: refs/heads/trunk c20e3bf8d -> f540f4a91 KAFKA-2586; Enable SSL for inter-broker communication when SSL is enabled in tests Author: Ismael Juma Reviewers: Jun Rao Closes #252 from

kafka git commit: KAFKA-2212: Authorizer CLI implementation.

Repository: kafka Updated Branches: refs/heads/trunk d03b871dd -> 5764e54de KAFKA-2212: Authorizer CLI implementation. Author: Parth Brahmbhatt Author: Ismael Juma Reviewers: Ismael Juma , Jun Rao Closes

svn commit: r10456 - in /release/kafka/0.8.2.2: ./ javadoc/ javadoc/org/ javadoc/org/apache/ javadoc/org/apache/kafka/ javadoc/org/apache/kafka/clients/ javadoc/org/apache/kafka/clients/producer/ java

Author: junrao Date: Wed Sep 9 21:19:50 2015 New Revision: 10456 Log: Apache Kafka 0.8.2.2 release [This commit notification would consist of 314 parts, which exceeds the limit of 50 ones, so it was shortened to the summary.]

kafka git commit: KAFKA-2576; ConsumerPerformance hangs when SSL enabled for Multi-Partition Topic

Repository: kafka Updated Branches: refs/heads/trunk b9ceac3ac -> 54dd6e3ad KAFKA-2576; ConsumerPerformance hangs when SSL enabled for Multi-Partition Topic We now write to the channel with an empty buffer when there are pending bytes remaining and all data has been sent. Author: Ismael Juma

kafka git commit: KAFKA-2211: Adding simpleAclAuthorizer implementation and test cases.

Repository: kafka Updated Branches: refs/heads/trunk 6ec88f7f8 -> 0990b6ba6 KAFKA-2211: Adding simpleAclAuthorizer implementation and test cases. Author: Parth Brahmbhatt Reviewers: Ismael Juma , Jun Rao Closes #195 from

kafka git commit: KAFKA-2582; ConsumerMetdata authorization error not returned to user

Repository: kafka Updated Branches: refs/heads/trunk 10d5deac0 -> ad120d578 KAFKA-2582; ConsumerMetdata authorization error not returned to user Author: Jason Gustafson Reviewers: Jun Rao Closes #245 from hachikuji/KAFKA-2582 Project:

[2/2] kafka git commit: KAFKA-2668; Add a metric that records the total number of metrics

KAFKA-2668; Add a metric that records the total number of metrics onurkaraman becketqin Do you have time to review this patch? It addresses the ticket that jjkoshy filed in KAFKA-2668. Author: Dong Lin Reviewers: Onur Karaman , Joel Koshy

kafka git commit: KAFKA-2642; Run replication tests with SSL and SASL clients

Repository: kafka Updated Branches: refs/heads/trunk 69269e76a -> cff03f8b6 KAFKA-2642; Run replication tests with SSL and SASL clients For SSL and SASL replication tests, set security protocol for clients as well. Author: Rajini Sivaram Reviewers: Ismael Juma

kafka git commit: KAFKA-3051 KAFKA-3048; Security config docs improvements

Repository: kafka Updated Branches: refs/heads/trunk b93f48f74 -> 57df460f8 KAFKA-3051 KAFKA-3048; Security config docs improvements Author: Ismael Juma Reviewers: Jun Rao Closes #724 from ijuma/minor-security-fixes Project:

kafka git commit: KAFKA-3051 KAFKA-3048; Security config docs improvements

Repository: kafka Updated Branches: refs/heads/0.9.0 71868da5c -> 4a236945e KAFKA-3051 KAFKA-3048; Security config docs improvements Author: Ismael Juma Reviewers: Jun Rao Closes #724 from ijuma/minor-security-fixes (cherry picked from commit

kafka git commit: KAFKA-3010; Include error in log when ack 0

Repository: kafka Updated Branches: refs/heads/0.9.0 5b5f002fc -> 2a9869e91 KAFKA-3010; Include error in log when ack 0 I verified this by trying to produce to __consumer_offsets and the logged message looks like: [2015-12-22 10:34:40,897] INFO [KafkaApi-0] Closing connection due to error

kafka git commit: KAFKA-3010; Include error in log when ack 0

Repository: kafka Updated Branches: refs/heads/trunk 23d607dc2 -> 5db147c1d KAFKA-3010; Include error in log when ack 0 I verified this by trying to produce to __consumer_offsets and the logged message looks like: [2015-12-22 10:34:40,897] INFO [KafkaApi-0] Closing connection due to error

kafka git commit: KAFKA-3045; ZkNodeChangeNotificationListener shouldn't log InterruptedException as error

Repository: kafka Updated Branches: refs/heads/0.9.0 2a9869e91 -> 870cd3607 KAFKA-3045; ZkNodeChangeNotificationListener shouldn't log InterruptedException as error Author: Dong Lin Reviewers: Ismael Juma , Jun Rao Closes #731

kafka git commit: KAFKA-2874; shutdown ZK process reliably

Repository: kafka Updated Branches: refs/heads/trunk 85039ab43 -> d9cabfde6 KAFKA-2874; shutdown ZK process reliably Author: Michael G. Noll Reviewers: Flavio Junqueira , Jun Rao Closes #573 from miguno/KAFKA-2874 Project:

kafka git commit: KAFKA-2937; Disable the leaderIsr check if the topic is to be deleted.

Repository: kafka Updated Branches: refs/heads/trunk 25fa39d5e -> a788c65f0 KAFKA-2937; Disable the leaderIsr check if the topic is to be deleted. The check was implemented in KAFKA-340 : If we are shutting down a broker when the ISR of a partition includes only that broker, we could lose

kafka git commit: KAFKA-2988; Change default configuration of the log cleaner

Repository: kafka Updated Branches: refs/heads/0.9.0 4ea380331 -> 2861665d1 KAFKA-2988; Change default configuration of the log cleaner Author: Grant Henke Reviewers: Ismael Juma , Jun Rao Closes #686 from granthenke/compaction

kafka git commit: KAFKA-2732; Add class for ZK Auth.

Repository: kafka Updated Branches: refs/heads/trunk 1dd558aec -> 4a8acdf9d KAFKA-2732; Add class for ZK Auth. Author: Flavio Junqueira Reviewers: Ismael Juma , Ben Stopford , Jun Rao Closes #410 from

kafka git commit: trivial doc fix to add link to Quotas

Repository: kafka Updated Branches: refs/heads/trunk c213952fa -> 5a9b12eb5 trivial doc fix to add link to Quotas Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/5a9b12eb Tree:

kafka git commit: trivial doc fix to add link to Quotas

Repository: kafka Updated Branches: refs/heads/0.9.0 fc7243c2a -> 10b3e6a5e trivial doc fix to add link to Quotas Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/10b3e6a5 Tree:

kafka-site git commit: Add 0.9.0.0 to downloads page

Repository: kafka-site Updated Branches: refs/heads/asf-site 7cf41c36d -> 56d48ce6b Add 0.9.0.0 to downloads page Project: http://git-wip-us.apache.org/repos/asf/kafka-site/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka-site/commit/56d48ce6 Tree:

kafka-site git commit: mino change to add link to quotas section

Repository: kafka-site Updated Branches: refs/heads/asf-site 497322d53 -> 346f93e64 mino change to add link to quotas section Project: http://git-wip-us.apache.org/repos/asf/kafka-site/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka-site/commit/346f93e6 Tree:

kafka git commit: KAFKA-2860: better handling of auto commit errors

Repository: kafka Updated Branches: refs/heads/0.9.0 26f797931 -> 07e214130 KAFKA-2860: better handling of auto commit errors Author: Jason Gustafson Reviewers: Guozhang Wang Closes #553 from hachikuji/KAFKA-2860 Project:

kafka git commit: KAFKA-2869; Host used by Authorizer should be IP address not hostname/IP

Repository: kafka Updated Branches: refs/heads/0.9.0 07e214130 -> 2b3f6d204 KAFKA-2869; Host used by Authorizer should be IP address not hostname/IP Author: Ismael Juma Reviewers: Jun Rao Closes #567 from

kafka git commit: KAFKA-2869; Host used by Authorizer should be IP address not hostname/IP

Repository: kafka Updated Branches: refs/heads/trunk 8ee9846e0 -> d0614f97b KAFKA-2869; Host used by Authorizer should be IP address not hostname/IP Author: Ismael Juma Reviewers: Jun Rao Closes #567 from

kafka git commit: KAFKA-2863; Add a `close()` method to `Authorizer`

Repository: kafka Updated Branches: refs/heads/0.9.0 2f51ab23a -> 81c89e91f KAFKA-2863; Add a `close()` method to `Authorizer` Author: Ismael Juma Reviewers: Jun Rao Closes #568 from ijuma/kafka-2863-authorizer-close (cherry picked from commit

kafka-site git commit: trivial change to 0.9.0 docs to fix incorrect ssl.key.password

Repository: kafka-site Updated Branches: refs/heads/asf-site 0b980bfa9 -> 0e79d903e trivial change to 0.9.0 docs to fix incorrect ssl.key.password Project: http://git-wip-us.apache.org/repos/asf/kafka-site/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka-site/commit/0e79d903 Tree:

kafka git commit: trivial change to 0.9.0 docs to fix outdated ConsumerMetadataRequest

Repository: kafka Updated Branches: refs/heads/trunk 9b0ddc555 -> b609645dc trivial change to 0.9.0 docs to fix outdated ConsumerMetadataRequest Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/b609645d Tree:

kafka git commit: trivial change to 0.9.0 docs to fix outdated ConsumerMetadataRequest

Repository: kafka Updated Branches: refs/heads/0.9.0 81c89e91f -> cd7455c64 trivial change to 0.9.0 docs to fix outdated ConsumerMetadataRequest Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/cd7455c6 Tree:

kafka git commit: trivial change to 0.9.0 docs to fix incorrect ssl.key.password

Repository: kafka Updated Branches: refs/heads/trunk b609645dc -> a7726ee65 trivial change to 0.9.0 docs to fix incorrect ssl.key.password Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/a7726ee6 Tree:

kafka git commit: trivial change to 0.9.0 docs to fix incorrect ssl.key.password

Repository: kafka Updated Branches: refs/heads/0.9.0 cd7455c64 -> 6aeaa1eb5 trivial change to 0.9.0 docs to fix incorrect ssl.key.password Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/6aeaa1eb Tree:

kafka-site git commit: trivial 0.9.0 doc fixes

Repository: kafka-site Updated Branches: refs/heads/asf-site dbcd9fd14 -> 0b980bfa9 trivial 0.9.0 doc fixes Project: http://git-wip-us.apache.org/repos/asf/kafka-site/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka-site/commit/0b980bfa Tree:

kafka git commit: trivial change: revert incorrect change to ssl.key.password

Repository: kafka Updated Branches: refs/heads/0.9.0 1742937cb -> fc7243c2a trivial change: revert incorrect change to ssl.key.password Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/fc7243c2 Tree:

kafka-site git commit: trivial change: revert incorrect change to ssl.key.password

Repository: kafka-site Updated Branches: refs/heads/asf-site 0e79d903e -> 7cf41c36d trivial change: revert incorrect change to ssl.key.password Project: http://git-wip-us.apache.org/repos/asf/kafka-site/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka-site/commit/7cf41c36 Tree:

Git Push Summary

Repository: kafka Updated Tags: refs/tags/0.9.0.0 [deleted] b88728681

Git Push Summary

Repository: kafka Updated Tags: refs/tags/0.9.0.0 [created] 132943b0f

kafka git commit: KAFKA-3085; BrokerChangeListener computes inconsistent live/dead broker list

Repository: kafka Updated Branches: refs/heads/trunk f009c3094 -> e789a35d3 KAFKA-3085; BrokerChangeListener computes inconsistent live/dead broker list Author: David Jacot Reviewers: Ismael Juma , Jun Rao Closes #752 from

kafka git commit: KAFKA-3682; ArrayIndexOutOfBoundsException thrown by

Repository: kafka Updated Branches: refs/heads/trunk 55225bd55 -> 756ec494d KAFKA-3682; ArrayIndexOutOfBoundsException thrown by SkimpyOffsetMap.get() when full Limited number of attempts to number of map slots after the internal positionOf() goes into linear search mode. Added unit test

kafka git commit: KAFKA-3085; BrokerChangeListener computes inconsistent live/dead broker list.

Repository: kafka Updated Branches: refs/heads/trunk a071e3554 -> 60a5a523b KAFKA-3085; BrokerChangeListener computes inconsistent live/dead broker list. Follow up PR as per comments in the ticket. junrao It should be correct now as `curBrokers` included only live brokers and live/d

kafka git commit: KAFKA-3159; stale high watermark segment offset causes early fetch return

Repository: kafka Updated Branches: refs/heads/0.9.0 99ed1e37c -> 728e14e25 KAFKA-3159; stale high watermark segment offset causes early fetch return Author: Jason Gustafson Reviewers: Ismael Juma , Jun Rao Closes #884 from

kafka git commit: change release version to 0.9.0.1

Repository: kafka Updated Branches: refs/heads/0.9.0 f232f53a7 -> 23c69d62a change release version to 0.9.0.1 Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/23c69d62 Tree:

[kafka] Git Push Summary

Repository: kafka Updated Tags: refs/tags/0.9.0.1 [created] 2c17685a4

kafka git commit: KAFKA-3152; kafka-acl doesn't allow space in principal name

Repository: kafka Updated Branches: refs/heads/trunk 22de0a8ab -> 523562c10 KAFKA-3152; kafka-acl doesn't allow space in principal name * Add quotes to `$` in shell scripts This is necessary for correct processing of quotes in the user command. * Minor improvements to AclCommand messages *

[1/2] kafka git commit: KAFKA-3259 KAFKA-3253; KIP-31/KIP-32 Follow-up

Repository: kafka Updated Branches: refs/heads/trunk 1bfaddae9 -> 01aeea7c7 http://git-wip-us.apache.org/repos/asf/kafka/blob/01aeea7c/core/src/main/scala/kafka/server/KafkaConfig.scala -- diff --git

kafka git commit: KAFKA-3256; Add print.timestamp option to console consumer.

Repository: kafka Updated Branches: refs/heads/trunk ff7b0f5b4 -> d142f8294 KAFKA-3256; Add print.timestamp option to console consumer. Author: Jiangjie Qin Reviewers: Jun Rao Closes #949 from becketqin/KAFKA-3256 Project:

kafka git commit: KAFKA-3292; ClientQuotaManager.getOrCreateQuotaSensors() may return a null ClientSensors.throttleTimeSensor

Repository: kafka Updated Branches: refs/heads/trunk b3b533171 -> af1699bcc KAFKA-3292; ClientQuotaManager.getOrCreateQuotaSensors() may return a null ClientSensors.throttleTimeSensor Author: Ismael Juma Reviewers: Jun Rao Closes #977 from

kafka git commit: MINOR: Validate inner message compression attribute

Repository: kafka Updated Branches: refs/heads/trunk af1699bcc -> 62945280a MINOR: Validate inner message compression attribute Author: Ismael Juma Reviewers: Jun Rao Closes #976 from ijuma/validate-inner-message-compression-attribute Project:

[2/2] kafka git commit: KAFKA-3259 KAFKA-3253; KIP-31/KIP-32 Follow-up

KAFKA-3259 KAFKA-3253; KIP-31/KIP-32 Follow-up This PR includes a number of clean-ups: * Code style * Documentation wording improvements * Efficiency improvements Author: Ismael Juma Reviewers: Jun Rao Closes #943 from ijuma/kafka-3259-kip-31-32-clean-ups

kafka git commit: KAFKA-3100; Broker.createBroker should work if json is version > 2 and still compatible

Repository: kafka Updated Branches: refs/heads/trunk 9f21837e9 -> 30d3cc631 KAFKA-3100; Broker.createBroker should work if json is version > 2 and still compatible Author: Ismael Juma Reviewers: Grant Henke , Jun Rao Closes #773

kafka git commit: KAFKA-3100; Broker.createBroker should work if json is version > 2 and still compatible

Repository: kafka Updated Branches: refs/heads/0.9.0 1e61327b9 -> 920326a01 KAFKA-3100; Broker.createBroker should work if json is version > 2 and still compatible Author: Ismael Juma Reviewers: Grant Henke , Jun Rao Closes #773

kafka git commit: KAFKA-3076; BrokerChangeListener should log the brokers in order

Repository: kafka Updated Branches: refs/heads/trunk fa6b90f97 -> 9f21837e9 KAFKA-3076; BrokerChangeListener should log the brokers in order Author: Konrad Author: konradkalita Reviewers: Ismael Juma , Jun Rao

[1/5] kafka git commit: KAFKA-3025; Added timetamp to Message and use relative offset.

Repository: kafka Updated Branches: refs/heads/trunk eee95228f -> 45c8195fa http://git-wip-us.apache.org/repos/asf/kafka/blob/45c8195f/core/src/test/scala/unit/kafka/message/ByteBufferMessageSetTest.scala -- diff --git

[3/5] kafka git commit: KAFKA-3025; Added timetamp to Message and use relative offset.

http://git-wip-us.apache.org/repos/asf/kafka/blob/45c8195f/core/src/main/scala/kafka/log/FileMessageSet.scala -- diff --git a/core/src/main/scala/kafka/log/FileMessageSet.scala b/core/src/main/scala/kafka/log/FileMessageSet.scala

[4/5] kafka git commit: KAFKA-3025; Added timetamp to Message and use relative offset.

http://git-wip-us.apache.org/repos/asf/kafka/blob/45c8195f/clients/src/test/java/org/apache/kafka/clients/consumer/MockConsumerTest.java -- diff --git

[3/3] kafka-site git commit: updating docs for 0.9.0.1 release

updating docs for 0.9.0.1 release Project: http://git-wip-us.apache.org/repos/asf/kafka-site/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka-site/commit/7f47d190 Tree: http://git-wip-us.apache.org/repos/asf/kafka-site/tree/7f47d190 Diff:

[2/3] kafka-site git commit: updating docs for 0.9.0.1 release

http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/org/apache/kafka/common/errors/AuthorizationException.html -- diff --git a/090/javadoc/org/apache/kafka/common/errors/AuthorizationException.html

kafka git commit: trivial fix to authorization CLI table

Repository: kafka Updated Branches: refs/heads/trunk 45c8195fa -> 5caa800e2 trivial fix to authorization CLI table Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/5caa800e Tree:

kafka-site git commit: trivial fix to authorization CLI table

Repository: kafka-site Updated Branches: refs/heads/asf-site 7f47d1901 -> 1bc5cd91c trivial fix to authorization CLI table Project: http://git-wip-us.apache.org/repos/asf/kafka-site/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka-site/commit/1bc5cd91 Tree:

kafka git commit: trivial change to make release version 0.9.0.2-SNAPSHOT

Repository: kafka Updated Branches: refs/heads/0.9.0 c991f9f74 -> f91d993a5 trivial change to make release version 0.9.0.2-SNAPSHOT Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/f91d993a Tree:

kafka git commit: KAFKA-3273; MessageFormatter and MessageReader interfaces should be resilient to changes

Repository: kafka Updated Branches: refs/heads/trunk 74eff8a83 -> 695fdc69d KAFKA-3273; MessageFormatter and MessageReader interfaces should be resilient to changes * Change `MessageFormat.writeTo` to take a `ConsumerRecord` * Change `MessageReader.readMessage()` to use `ProducerRecord`

[2/2] kafka git commit: KAFKA-1215; Rack-Aware replica assignment option

KAFKA-1215; Rack-Aware replica assignment option Please see https://cwiki.apache.org/confluence/display/KAFKA/KIP-36+Rack+aware+replica+assignment for the overall design. The update to TopicMetadataRequest/TopicMetadataResponse will be done in a different PR. Author: Allen Wang

<    1   2   3   4   5   6   7   8   9   10   >