Repository: kafka
Updated Branches:
refs/heads/trunk b8cfa167e -> 2965f50e0
MINOR: Replaced unnecessary map and getOrElse with exists
Author: himani1 <1himani.ar...@gmail.com>
Reviewers: Jason Gustafson
Closes #2035 from himani1/code_refactored
Project: http://git-wip-us.apache.org/repos/
Repository: kafka
Updated Branches:
refs/heads/trunk 2965f50e0 -> 332b8b9af
KAFKA-4319; Parallelize shutdown of fetchers in AbstractFetcherManager to
speedup shutdown
Author: Alexey Ozeritsky
Reviewers: Ismael Juma , Jason Gustafson
Closes #2023 from resetius/AbstractFetcherManager-shutdo
Repository: kafka
Updated Tags: refs/tags/0.10.1.0 [created] 88d865799
Repository: kafka
Updated Branches:
refs/heads/0.10.1 b729ac520 -> fb3f1f978
Bump version to 0.10.1.1-SNAPSHOT
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/fb3f1f97
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tre
Bump version to 0.10.1.0
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/5bdcbebd
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/5bdcbebd
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/5bdcbebd
Branch: refs/
Author: jgus
Date: Wed Oct 19 18:39:44 2016
New Revision: 16588
Log:
Add 0.10.1.0 artifacs so that PMC can promote them
[This commit notification would consist of 75 parts,
which exceeds the limit of 50 ones, so it was shortened to the summary.]
Repository: kafka-site
Updated Branches:
refs/heads/asf-site 230d32e67 -> 9bad5a3b7
Resync 0.10.1 for 0.10.1.0 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/9bad5a3b
Tree: http://git-wip-us.apache.org/r
Update download page for 0.10.1.0
Project: http://git-wip-us.apache.org/repos/asf/kafka-site/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka-site/commit/12ad81e4
Tree: http://git-wip-us.apache.org/repos/asf/kafka-site/tree/12ad81e4
Diff: http://git-wip-us.apache.org/repos/asf/kafka-site
Repository: kafka-site
Updated Branches:
refs/heads/asf-site 9bad5a3b7 -> 12ad81e44
Enable 0.10.1 documentation
Project: http://git-wip-us.apache.org/repos/asf/kafka-site/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka-site/commit/ac2567c7
Tree: http://git-wip-us.apache.org/repos/as
Repository: kafka
Updated Branches:
refs/heads/trunk 62c0972ef -> 5cf579a7e
MINOR: Fix vagrant rsync exclude argument
Existing VMs will need to be re-provisioned or re-created to pick up this
change.
Reference docs:
https://www.vagrantup.com/docs/synced-folders/rsync.html
Author: Magnus Ede
Repository: kafka
Updated Branches:
refs/heads/trunk 2ac70c0b7 -> 302a246c7
KAFKA-4296; Fix LogCleaner statistics rolling
Author: Jason Gustafson
Reviewers: Ismael Juma
Closes #2016 from hachikuji/KAFKA-4296
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wi
Repository: kafka
Updated Branches:
refs/heads/trunk 74014af83 -> 7afdad8c3
KAFKA-3144; Report members with no assigned partitions in ConsumerGroupCommand
This PR makes a couple of enhancements to the `--describe` option of
`ConsumerGroupCommand`:
1. Listing members with no assigned partition
Repository: kafka
Updated Branches:
refs/heads/trunk dab3617e1 -> 53fc26723
MINOR: Increase zk connection timeout in tests for client created in
`KafkaServer`
We had already made this change to the client created in `ZooKeeperTestHarness`.
I last saw this failure when
`SaslPlaintextTopicMeta
Repository: kafka
Updated Branches:
refs/heads/trunk 53fc26723 -> 34e9cc5df
KAFKA-4349; Handle 'PreparingRebalance' and 'AwaitingSync' states in consumer
group describe
The edge case where consumer group state is `PreparingRebalance` or
`AwaitingSync` will be separately handled as the group
Repository: kafka
Updated Branches:
refs/heads/trunk 76b070284 -> 979a7baa7
MINOR: Fix issue in `AsyncProducerTest` where it expects the `port` config to
be set
This test fails locally when I run it, but somehow Jenkins builds are passed.
Not clear how.
Author: Ismael Juma
Reviewers: Jaso
Repository: kafka
Updated Branches:
refs/heads/trunk fbbe5821c -> 94909a8f8
KAFKA-4357; Fix consumer group describe output when there is no active member
(old consumer)
Author: Vahid Hashemian
Reviewers: Sriharsha Chintalapani , Jason Gustafson
Closes #2075 from vahidhashemian/KAFKA-4357
Repository: kafka
Updated Branches:
refs/heads/trunk c62dc28ce -> 2959bc2ad
MINOR: Replaced unnecessary isDefined and get on option values with fold
Author: himani1 <1himani.ar...@gmail.com>
Reviewers: Jason Gustafson
Closes #2050 from himani1/refactored_code
Project: http://git-wip-us.ap
Repository: kafka
Updated Branches:
refs/heads/trunk 1a2ed8633 -> e795ad96c
KAFKA-4024; Override client metadata backoff on topic changes and avoid
unnecessary connections
Fixes a bug that inappropriately applies backoff as interval between metadata
updates even though the current one is out
Repository: kafka
Updated Branches:
refs/heads/trunk e795ad96c -> 5e7190cf8
MINOR: Add description of how consumer wakeup acts if no threads are awakened
I think the Javadoc should describe what happens if wakeup is called and no
other thread is currently blocking. This may be important in so
Repository: kafka
Updated Branches:
refs/heads/trunk 5307efe1a -> 8f2e0a5ec
MINOR: Fix regex on connector path param in ConnectorsResource
Author: Ewen Cheslack-Postava
Reviewers: Shikhar Bhushan , Konstantine Karantasis
, Jason Gustafson
Closes #2108 from ewencp/fix-rest-api-regex
Proj
Repository: kafka
Updated Branches:
refs/heads/trunk 64a860c58 -> 7282de39f
KAFKA-4081; KafkaConsumer should not allow negative offsets to be committed
Author: Mickael Maison
Reviewers: Jiangjie Qin , Jason Gustafson
Closes #1827 from mimaison/KAFKA-4081
Project: http://git-wip-us.apach
Repository: kafka
Updated Branches:
refs/heads/trunk 1f1d45006 -> 3b4c34794
http://git-wip-us.apache.org/repos/asf/kafka/blob/3b4c3479/core/src/main/scala/kafka/server/KafkaApis.scala
--
diff --git a/core/src/main/scala/kafka/s
http://git-wip-us.apache.org/repos/asf/kafka/blob/3b4c3479/clients/src/main/java/org/apache/kafka/common/record/LogInputStream.java
--
diff --git
a/clients/src/main/java/org/apache/kafka/common/record/LogInputStream.java
b/client
http://git-wip-us.apache.org/repos/asf/kafka/blob/3b4c3479/clients/src/main/java/org/apache/kafka/common/requests/RequestSend.java
--
diff --git
a/clients/src/main/java/org/apache/kafka/common/requests/RequestSend.java
b/clients/
http://git-wip-us.apache.org/repos/asf/kafka/blob/3b4c3479/clients/src/test/java/org/apache/kafka/clients/producer/internals/SenderTest.java
--
diff --git
a/clients/src/test/java/org/apache/kafka/clients/producer/internals/SenderT
KAFKA-2066; Use client-side FetchRequest/FetchResponse on server
Author: Jason Gustafson
Reviewers: Jun Rao
Closes #2069 from hachikuji/KAFKA-2066
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/3b4c3479
Tree: http://git-
Repository: kafka
Updated Branches:
refs/heads/trunk 3b4c34794 -> a32962af1
HOTFIX: Remove failing ConnectDistributedTest.test_bad_connector_class
Since #1911 was merged it is hard to externally test a connector transitioning
to FAILED state due to an initialization failure, which is what thi
Repository: kafka
Updated Branches:
refs/heads/trunk 31203efcb -> b902ef985
MINOR: Remove unused `ByteBoundedBlockingQueue` class and `zkSessionTimeout`
parameter
Author: Ismael Juma
Reviewers: Jason Gustafson
Closes #2136 from ijuma/remove-unused-code
Project: http://git-wip-us.apache.
Repository: kafka
Updated Branches:
refs/heads/trunk 04a13e82a -> 249e41368
KAFKA-4211; Update system test services to use the new consumer by default
Update system test method signatures and method calls to use the new consumer
by default.
Author: Vahid Hashemian
Reviewers: Jason Gustafso
Repository: kafka
Updated Branches:
refs/heads/trunk d98ca230a -> 5819b06fa
KAFKA-4403; Update KafkaBasedLog to use new endOffsets consumer API
ewencp plz review
Author: Balint Molnar
Reviewers: Jason Gustafson
Closes #2176 from baluchicken/KAFKA-4403
Project: http://git-wip-us.apache.o
Repository: kafka
Updated Branches:
refs/heads/trunk 5819b06fa -> 1503f7603
KAFKA-4387; KafkaConsumer should properly handle interrupts
See https://issues.apache.org/jira/browse/KAFKA-4387
Author: Stig Rohde Døssing
Reviewers: Ismael Juma , Jason Gustafson
Closes #2110 from srdo/KAFKA-43
Repository: kafka
Updated Branches:
refs/heads/trunk 8d188c911 -> f9d7808ba
KAFKA-4469; Fix consumer performance regression from inefficient list removal
and copy
Author: Jason Gustafson
Reviewers: Ismael Juma , Guozhang Wang
Closes #2190 from hachikuji/KAFKA-4469
Project: http://git-wi
Repository: kafka
Updated Branches:
refs/heads/0.10.1 b1f8fc7b6 -> aec74ae5b
KAFKA-4469; Fix consumer performance regression from inefficient list removal
and copy
Author: Jason Gustafson
Reviewers: Ismael Juma , Guozhang Wang
Closes #2190 from hachikuji/KAFKA-4469
(cherry picked from co
Repository: kafka
Updated Branches:
refs/heads/trunk b45a67ede -> ea370be51
KAFKA-4399; Fix deadlock between cleanupGroupMetadata and offset commit
Author: Alexey Ozeritsky
Reviewers: Ismael Juma , Jason Gustafson
Closes #2125 from resetius/KAFKA-4399
Project: http://git-wip-us.apache.or
Repository: kafka
Updated Branches:
refs/heads/0.10.1 9ffadbfdc -> 0e20e5fbf
KAFKA-4399; Fix deadlock between cleanupGroupMetadata and offset commit
Author: Alexey Ozeritsky
Reviewers: Ismael Juma , Jason Gustafson
Closes #2125 from resetius/KAFKA-4399
(cherry picked from commit ea370be51
Repository: kafka
Updated Branches:
refs/heads/trunk b06fc322b -> e43bbce49
KAFKA-4483; Fix NPE in `Log` constructor if log level is INFO or finer
Author: Ismael Juma
Reviewers: Jason Gustafson
Closes #2207 from ijuma/kafka-4483-npe-in-log-constructor
Project: http://git-wip-us.apache.or
Repository: kafka
Updated Branches:
refs/heads/trunk 01d58ad8e -> 36528df08
MINOR: Fix typos in KafkaConsumer docs
Author: Jeff Widman
Reviewers: Jason Gustafson
Closes #2178 from jeffwidman/patch-1
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apac
Repository: kafka
Updated Branches:
refs/heads/trunk 36528df08 -> 9684487b4
KAFKA-4375; Reset interrupt state in a few places where InterruptedException is
caught
See https://issues.apache.org/jira/browse/KAFKA-4375
Author: Stig Rohde Døssing
Reviewers: Jason Gustafson
Closes #2100 from
Repository: kafka
Updated Branches:
refs/heads/trunk 9684487b4 -> 055ca9b7a
KAFKA-4272; Add missing 'connect' Windows batch scripts
Author: Vahid Hashemian
Reviewers: Jason Gustafson
Closes #2146 from vahidhashemian/KAFKA-4272
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Co
Repository: kafka
Updated Branches:
refs/heads/trunk 055ca9b7a -> 7f8edbc8e
KAFKA-4000; Collect and record per-topic consumer metrics
Improve consumer metric collection by collecting and recording metrics per
topic.
Author: Vahid Hashemian
Reviewers: Jason Gustafson
Closes #1684 from vah
Repository: kafka
Updated Branches:
refs/heads/trunk f0acc4a0d -> efeaf1298
KAFKA-4405; Avoid unnecessary network poll in consumer if no fetches sent
Author: Eno Thereska
Reviewers: Ismael Juma , Jason Gustafson
Closes #2193 from enothereska/KAFKA-4405-prefetch
Project: http://git-wip-us
Repository: kafka
Updated Branches:
refs/heads/trunk 6626b058c -> 67f1e5b91
http://git-wip-us.apache.org/repos/asf/kafka/blob/67f1e5b9/core/src/test/scala/unit/kafka/server/FetchRequestTest.scala
--
diff --git a/core/src/test/s
http://git-wip-us.apache.org/repos/asf/kafka/blob/67f1e5b9/core/src/test/scala/unit/kafka/log/LogTest.scala
--
diff --git a/core/src/test/scala/unit/kafka/log/LogTest.scala
b/core/src/test/scala/unit/kafka/log/LogTest.scala
index
http://git-wip-us.apache.org/repos/asf/kafka/blob/67f1e5b9/clients/src/main/java/org/apache/kafka/common/record/RecordsIterator.java
--
diff --git
a/clients/src/main/java/org/apache/kafka/common/record/RecordsIterator.java
b/clie
http://git-wip-us.apache.org/repos/asf/kafka/blob/67f1e5b9/core/src/test/scala/unit/kafka/log/LogCleanerIntegrationTest.scala
--
diff --git a/core/src/test/scala/unit/kafka/log/LogCleanerIntegrationTest.scala
b/core/src/test/scala
http://git-wip-us.apache.org/repos/asf/kafka/blob/67f1e5b9/core/src/main/scala/kafka/server/ReplicaManager.scala
--
diff --git a/core/src/main/scala/kafka/server/ReplicaManager.scala
b/core/src/main/scala/kafka/server/ReplicaManag
KAFKA-4390; Replace MessageSet usage with client-side alternatives
Author: Jason Gustafson
Reviewers: Ismael Juma , Guozhang Wang ,
Jun Rao
Closes #2140 from hachikuji/KAFKA4390
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/c
http://git-wip-us.apache.org/repos/asf/kafka/blob/67f1e5b9/clients/src/main/java/org/apache/kafka/common/record/LogInputStream.java
--
diff --git
a/clients/src/main/java/org/apache/kafka/common/record/LogInputStream.java
b/client
http://git-wip-us.apache.org/repos/asf/kafka/blob/67f1e5b9/clients/src/test/java/org/apache/kafka/common/record/RecordTest.java
--
diff --git
a/clients/src/test/java/org/apache/kafka/common/record/RecordTest.java
b/clients/src/te
http://git-wip-us.apache.org/repos/asf/kafka/blob/67f1e5b9/core/src/main/scala/kafka/log/LogSegment.scala
--
diff --git a/core/src/main/scala/kafka/log/LogSegment.scala
b/core/src/main/scala/kafka/log/LogSegment.scala
index c5418e
MINOR: Replace deepIterator/shallowIterator with deepEntries/shallowEntries
The latter return `Iterable` instead of `Iterator` so that enhanced foreach can
be used
in Java.
Author: Ismael Juma
Reviewers: Jason Gustafson
Closes #2261 from ijuma/deepEntries-shallowEntries
Project: http://git
Repository: kafka
Updated Branches:
refs/heads/trunk e55205b81 -> b58b6a1be
http://git-wip-us.apache.org/repos/asf/kafka/blob/b58b6a1b/core/src/test/scala/unit/kafka/server/FetchRequestTest.scala
--
diff --git a/core/src/test/s
Repository: kafka
Updated Branches:
refs/heads/trunk 65acff32d -> bc9ef716a
KAFKA-4553; Improve round robin assignment in Connect to avoid uneven
distributions of connectors and tasks
Author: Ewen Cheslack-Postava
Reviewers: Konstantine Karantasis , Jason Gustafson
Closes #2272 from ewen
Repository: kafka
Updated Branches:
refs/heads/trunk 7f4b278c0 -> 3930dd7e7
KAFKA-4554; Fix ReplicaBuffer.verifyChecksum to use iterators instead of
iterables
This was changed in b58b6a1bef0 and caused the
`ReplicaVerificationToolTest.test_replica_lags`
system test to start failing.
I also
MINOR: Replace TopicAndPartition with TopicPartition in `Log` and
`ReplicaManager`
Author: Ismael Juma
Reviewers: Jason Gustafson
Closes #2268 from ijuma/topicpartition-vs-topicandpartition
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos
Repository: kafka
Updated Branches:
refs/heads/trunk 0f86dbe89 -> 68f204e01
http://git-wip-us.apache.org/repos/asf/kafka/blob/68f204e0/core/src/test/scala/unit/kafka/server/BaseReplicaFetchTest.scala
--
diff --git a/core/src/te
http://git-wip-us.apache.org/repos/asf/kafka/blob/68f204e0/core/src/main/scala/kafka/server/ReplicaManager.scala
--
diff --git a/core/src/main/scala/kafka/server/ReplicaManager.scala
b/core/src/main/scala/kafka/server/ReplicaManag
Repository: kafka
Updated Branches:
refs/heads/trunk 7f22ab655 -> a565a77b1
KAFKA-4404; Add javadocs to document core Connect types, especially that
integer types are signed
Author: Ewen Cheslack-Postava
Reviewers: Konstantine Karantasis , Jason Gustafson
Closes #2296 from ewencp/kafka-4
Repository: kafka
Updated Branches:
refs/heads/trunk a565a77b1 -> b565dd7eb
KAFKA-4429; Consumer lag metric should be zero if FetchResponse is empty
Author: Dong Lin
Reviewers: Ewen Cheslack-Postava , Jason Gustafson
Closes #2155 from lindong28/KAFKA-4429
Project: http://git-wip-us.apac
Repository: kafka
Updated Branches:
refs/heads/trunk ce1cb329d -> 6d6c77a7a
http://git-wip-us.apache.org/repos/asf/kafka/blob/6d6c77a7/core/src/main/scala/kafka/log/LogSegment.scala
--
diff --git a/core/src/main/scala/kafka/log
MINOR: Improvements to Record related classes (part 1)
Jason recently cleaned things up significantly by consolidating the
Message/Record classes
into the common Java code in the clients module. While reviewing that, I
noticed a few things
that could be improved a little more. To make reviewing
Repository: kafka
Updated Branches:
refs/heads/trunk ecff8544d -> f72203ee9
KAFKA-4426; Add close with timeout for KafkaConsumer (KIP-102)
Author: Rajini Sivaram
Reviewers: Ismael Juma , Apurva Mehta
, Jason Gustafson
Closes #2285 from rajinisivaram/KAFKA-4426
Project: http://git-wip-us
Repository: kafka
Updated Branches:
refs/heads/trunk 8d9d84790 -> 80d6c64c1
KAFKA-4626; Add KafkaConsumer#close change to upgrade notes
Author: Rajini Sivaram
Reviewers: Ismael Juma , Jason Gustafson
Closes #2366 from rajinisivaram/KAFKA-4626
Project: http://git-wip-us.apache.org/repos/a
Repository: kafka
Updated Branches:
refs/heads/trunk 80d6c64c1 -> d25671884
http://git-wip-us.apache.org/repos/asf/kafka/blob/d2567188/core/src/test/scala/unit/kafka/server/AdvertiseBrokerTest.scala
--
diff --git a/core/src/tes
KAFKA-4565; Separation of Internal and External traffic (KIP-103)
Author: Ismael Juma
Reviewers: Gwen Shapira , Jason Gustafson
Closes #2354 from ijuma/kafka-4565-separation-of-internal-and-external-traffic
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.
http://git-wip-us.apache.org/repos/asf/kafka/blob/d2567188/core/src/main/scala/kafka/server/KafkaConfig.scala
--
diff --git a/core/src/main/scala/kafka/server/KafkaConfig.scala
b/core/src/main/scala/kafka/server/KafkaConfig.scala
Repository: kafka
Updated Branches:
refs/heads/trunk 6496271a1 -> f6fee34a2
KAFKA-4627; Fix timing issue in consumer close tests
Author: Rajini Sivaram
Reviewers: Apurva Mehta , Jason Gustafson
Closes #2367 from rajinisivaram/KAFKA-4627
Project: http://git-wip-us.apache.org/repos/asf/ka
Repository: kafka
Updated Branches:
refs/heads/trunk 88fdca26a -> c2d9b95f3
http://git-wip-us.apache.org/repos/asf/kafka/blob/c2d9b95f/core/src/test/scala/unit/kafka/coordinator/GroupMetadataManagerTest.scala
--
diff --git
a/c
KAFKA-3853; Extend OffsetFetch API to allow fetching all offsets for a consumer
group (KIP-88)
Author: Vahid Hashemian
Reviewers: Ismael Juma , Ewen Cheslack-Postava
, Jason Gustafson
Closes #2074 from vahidhashemian/KAFKA-3853
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Com
KAFKA-4591; Create Topic Policy (KIP-108)
Author: Ismael Juma
Reviewers: Apurva Mehta , Gwen Shapira
, Jason Gustafson
Closes #2361 from ijuma/kafka-4591-create-topic-policy
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commi
Repository: kafka
Updated Branches:
refs/heads/trunk bc61d9bee -> da57bc27e
http://git-wip-us.apache.org/repos/asf/kafka/blob/da57bc27/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsKafkaClient.java
-
Repository: kafka
Updated Branches:
refs/heads/trunk 55abe65e0 -> 7a84b241e
MINOR: Some cleanups and additional testing for KIP-88
Author: Jason Gustafson
Reviewers: Vahid Hashemian , Ismael Juma
Closes #2383 from hachikuji/minor-cleanup-kip-88
Project: http://git-wip-us.apache.org/repo
Repository: kafka
Updated Branches:
refs/heads/0.10.2 2b19ad9d8 -> 60d759a22
MINOR: Some cleanups and additional testing for KIP-88
Author: Jason Gustafson
Reviewers: Vahid Hashemian , Ismael Juma
Closes #2383 from hachikuji/minor-cleanup-kip-88
Project: http://git-wip-us.apache.org/rep
Repository: kafka
Updated Branches:
refs/heads/trunk fd6d7bcf3 -> 1974e1b0e
KAFKA-3502; move RocksDB options construction to init()
In RocksDBStore, options / wOptions / fOptions are constructed in the
constructor, which needs to be dismissed in the close() call; however in some
tests, the g
Repository: kafka
Updated Branches:
refs/heads/0.10.2 eb62e5695 -> e38794e02
KAFKA-3502; move RocksDB options construction to init()
In RocksDBStore, options / wOptions / fOptions are constructed in the
constructor, which needs to be dismissed in the close() call; however in some
tests, the
Repository: kafka
Updated Branches:
refs/heads/trunk 5fc530bc4 -> 813897a00
KAFKA-4547; Avoid incorrect reset of paused partitions to the committed offsets
Author: Vahid Hashemian
Reviewers: Jason Gustafson
Closes #2341 from vahidhashemian/KAFKA-4547
Project: http://git-wip-us.apache.org
Repository: kafka
Updated Branches:
refs/heads/0.10.2 770bab399 -> 17dd4db29
KAFKA-4547; Avoid incorrect reset of paused partitions to the committed offsets
Author: Vahid Hashemian
Reviewers: Jason Gustafson
Closes #2341 from vahidhashemian/KAFKA-4547
Project: http://git-wip-us.apache.or
KAFKA-4633; Always using regex pattern subscription in StreamThread
1. In StreamThread, always use subscribe(Pattern, ..) function in order to
avoid sending MetadataRequest with specific topic names and cause brokers to
possibly auto-create subscribed topics; the pattern is generated as
"topic-
Repository: kafka
Updated Branches:
refs/heads/trunk 62206de4e -> 3400d0c3c
http://git-wip-us.apache.org/repos/asf/kafka/blob/3400d0c3/streams/src/main/java/org/apache/kafka/streams/processor/TopologyBuilder.java
--
diff --git
KAFKA-4633; Always using regex pattern subscription in StreamThread
1. In StreamThread, always use subscribe(Pattern, ..) function in order to
avoid sending MetadataRequest with specific topic names and cause brokers to
possibly auto-create subscribed topics; the pattern is generated as
"topic-
Repository: kafka
Updated Branches:
refs/heads/0.10.2 80ceb75d2 -> 0f87991d5
http://git-wip-us.apache.org/repos/asf/kafka/blob/0f87991d/streams/src/main/java/org/apache/kafka/streams/processor/TopologyBuilder.java
--
diff --git
Repository: kafka
Updated Branches:
refs/heads/trunk 79987590e -> bf5aebadb
MINOR: Add offset information to consumer_test error messages
Author: Jason Gustafson
Reviewers: Ismael Juma
Closes #2426 from hachikuji/improve-consumer-test-error-messages
Project: http://git-wip-us.apache.org/
Repository: kafka
Updated Branches:
refs/heads/0.10.1 027455146 -> c310a1bc6
KAFKA-4547; Avoid unnecessary offset commit that could lead to an invalid
offset position if partition is paused
Author: Vahid Hashemian
Reviewers: Jason Gustafson
Closes #2431 from vahidhashemian/KAFKA-4547-0.10
Repository: kafka
Updated Branches:
refs/heads/trunk 0971e62e5 -> 23f695196
KAFKA-4698; VerifyError in kafka/client/ClientUtils due to -target:jvm-1.7
Author: Ismael Juma
Reviewers: Jason Gustafson
Closes #2434 from ijuma/kafka-4698-target-1.7-verify-error
Project: http://git-wip-us.apac
Repository: kafka
Updated Branches:
refs/heads/0.10.2 1d2426683 -> 94c0da2b7
KAFKA-4698; VerifyError in kafka/client/ClientUtils due to -target:jvm-1.7
Author: Ismael Juma
Reviewers: Jason Gustafson
Closes #2434 from ijuma/kafka-4698-target-1.7-verify-error
(cherry picked from commit 23f6
Repository: kafka
Updated Branches:
refs/heads/trunk 23f695196 -> 8b3c6c0a1
KAFKA-4597; RecordMetadata should return log append time when appropriate
There is a slight change of behaviour: we now complete the `Future` returned
from `send`
before the callbacks are invoked. This seems OK and pe
Repository: kafka
Updated Branches:
refs/heads/0.10.2 94c0da2b7 -> e74a92463
KAFKA-4597; RecordMetadata should return log append time when appropriate
There is a slight change of behaviour: we now complete the `Future` returned
from `send`
before the callbacks are invoked. This seems OK and p
Repository: kafka
Updated Branches:
refs/heads/trunk 5b4e299a4 -> 254e3b77d
KAFKA-4699; Invoke producer callbacks before completing the future
This behaviour was changed in 8b3c6c0, but it caused interceptor
test failures (which rely on callbacks) and since weâre so close to
code freeze, itâ
Repository: kafka
Updated Branches:
refs/heads/0.10.2 8812d151a -> 29bc8905a
KAFKA-4699; Invoke producer callbacks before completing the future
This behaviour was changed in 8b3c6c0, but it caused interceptor
test failures (which rely on callbacks) and since weâre so close to
code freeze, it
Repository: kafka
Updated Branches:
refs/heads/trunk 0c83eddcd -> 1eac3f33f
MINOR: Change logging level for ignored maybeAddMetric from debug to trace
Author: Guozhang Wang
Reviewers: Eno Thereska , Xavier Léauté
, Jason Gustafson
Closes #2454 from guozhangwang/KMinor-trace-logging-add-
Repository: kafka
Updated Branches:
refs/heads/0.10.2 f68c7e0f3 -> af4f4df18
MINOR: Change logging level for ignored maybeAddMetric from debug to trace
Author: Guozhang Wang
Reviewers: Eno Thereska , Xavier Léauté
, Jason Gustafson
Closes #2454 from guozhangwang/KMinor-trace-logging-add
Repository: kafka
Updated Branches:
refs/heads/trunk a01b72236 -> 2f9e9195a
MINOR: Close create topics policy during shutdown and more tests
Author: Ismael Juma
Reviewers: Jason Gustafson
Closes #2443 from ijuma/close-create-topics-policy-during-shutdown
Project: http://git-wip-us.apache
Repository: kafka
Updated Branches:
refs/heads/0.10.2 5f1ab1419 -> b2bcef7f3
MINOR: Close create topics policy during shutdown and more tests
Author: Ismael Juma
Reviewers: Jason Gustafson
Closes #2443 from ijuma/close-create-topics-policy-during-shutdown
(cherry picked from commit 2f9e91
Repository: kafka
Updated Branches:
refs/heads/trunk b948f4327 -> 5afe95964
MINOR: Logging improvements in consumer internals
Author: Jason Gustafson
Reviewers: Manikumar reddy O , Ewen Cheslack-Postava
, Ismael Juma
Closes #2469 from hachikuji/improve-consumer-logging
Project: http://g
Repository: kafka
Updated Branches:
refs/heads/0.10.2 61024c9d2 -> a50635219
MINOR: Logging improvements in consumer internals
Author: Jason Gustafson
Reviewers: Manikumar reddy O , Ewen Cheslack-Postava
, Ismael Juma
Closes #2469 from hachikuji/improve-consumer-logging
(cherry picked fr
Repository: kafka
Updated Branches:
refs/heads/trunk 0b48ea1c8 -> cea461353
MINOR: Update docs for version 0.10.2.0
Author: Ewen Cheslack-Postava
Reviewers: Jason Gustafson
Closes #2480 from ewencp/docs-version-0.10.2.0
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: h
Repository: kafka
Updated Branches:
refs/heads/0.10.2 54512cbaf -> 9cf6f9790
MINOR: Update docs for version 0.10.2.0
Author: Ewen Cheslack-Postava
Reviewers: Jason Gustafson
Closes #2480 from ewencp/docs-version-0.10.2.0
(cherry picked from commit cea46135338150e409e140b8b96856e060be8780)
Repository: kafka
Updated Branches:
refs/heads/trunk 7ebc5da60 -> 88809b9b8
HOTFIX: Verifiable producer request timeout needs conversion to milliseconds
Author: Jason Gustafson
Reviewers: Ewen Cheslack-Postava
Closes #2494 from hachikuji/hotfix-verifiable-producer-request-timeout
Project
Repository: kafka
Updated Branches:
refs/heads/0.10.2 d952d94e5 -> 0578e2945
HOTFIX: Verifiable producer request timeout needs conversion to milliseconds
Author: Jason Gustafson
Reviewers: Ewen Cheslack-Postava
Closes #2494 from hachikuji/hotfix-verifiable-producer-request-timeout
(cherry
Repository: kafka
Updated Branches:
refs/heads/trunk 1f8a2ad2e -> b31a7a902
KAFKA-4728; KafkaConsumer#commitSync should copy its input
Author: Jan Lukavsky
Reviewers: Jason Gustafson
Closes #2491 from je-ik/KAFKA-4728
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: htt
401 - 500 of 2281 matches
Mail list logo
