This is an automated email from the ASF dual-hosted git repository.
jjkoshy pushed a change to branch jjkoshy-corruptlogissue
in repository https://gitbox.apache.org/repos/asf/kafka.git.
at 1711fb1 log message format version should be 0.10.0
This branch includes the following new
This is an automated email from the ASF dual-hosted git repository.
jjkoshy pushed a change to branch jjkoshy-corruptlogissue
in repository https://gitbox.apache.org/repos/asf/kafka.git.
at 1711fb1 log message format version should be 0.10.0
This branch includes the following new
This is an automated email from the ASF dual-hosted git repository.
jjkoshy pushed a change to branch jjkoshy-corruptlogissue
in repository https://gitbox.apache.org/repos/asf/kafka.git.
at 1711fb1 log message format version should be 0.10.0
This branch includes the following new
This is an automated email from the ASF dual-hosted git repository.
jjkoshy pushed a change to branch jjkoshy-corruptlogissue
in repository https://gitbox.apache.org/repos/asf/kafka.git.
at 1711fb1 log message format version should be 0.10.0
This branch includes the following new
This is an automated email from the ASF dual-hosted git repository.
jjkoshy pushed a change to branch jjkoshy-corruptlogissue
in repository https://gitbox.apache.org/repos/asf/kafka.git.
at 1711fb1 log message format version should be 0.10.0
This branch includes the following new
This is an automated email from the ASF dual-hosted git repository.
jjkoshy pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new b86e8c1 MINOR: add docs for KIP-354 KAFKA-7321
This is an automated email from the ASF dual-hosted git repository.
jjkoshy pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 1fdc853 KAFKA-7321: Add a Maximum Log Compaction
This is an automated email from the ASF dual-hosted git repository.
jjkoshy pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 8c47a3e KAFKA-5098; KafkaProducer should reject
est failures (MetricsTest) along
the way. jjkoshy , granders , avianey , you may be interested in this PR.
Author: Sumant Tambe
Author: Mayuresh Gharat
Author: MayureshGharat
Reviewers: Joel Koshy
Closes #1664 from sutambe/async-delete-topic
Project: http://git-wip-us.apache.org/repos/asf/ka
Repository: kafka
Updated Branches:
refs/heads/trunk b51002c57 -> 4a1f6
KAFKA-4250; Make ProducerRecord and ConsumerRecord extensible
Signed-off-by: radai-rosenblatt
Author: radai-rosenblatt
Reviewers: Joel Koshy
Closes #1961 from radai-rosenblatt/extensibility
Project: http://git-
Repository: kafka
Updated Branches:
refs/heads/trunk c04486f4a -> 83116c733
KAFKA-4025; make sure file.encoding system property is set to UTF-8 when
calling rat
https://issues.apache.org/jira/browse/KAFKA-4025
this patch sets the file.encoding system property to UTF-8 before invoking rat
dur
Repository: kafka
Updated Branches:
refs/heads/trunk bf98c4738 -> 1bce0d1b5
KAFKA-3175; Topic not accessible after deletion even when delete.topic.enable
is disabled
Remove topics under /admin/delete_topics path in zk if deleteTopic is disabled.
The topic should never be enqueued for deletio
Repository: kafka
Updated Branches:
refs/heads/trunk 2a660f13d -> 41e676d29
KAFKA-4158; Reset quota to default value if quota override is deleted
Author: Dong Lin
Reviewers: Joel Koshy , Jiangjie Qin
Closes #1851 from lindong28/KAFKA-4158
Project: http://git-wip-us.apache.org/repos/asf/k
Repository: kafka
Updated Branches:
refs/heads/0.10.0 a707f573d -> afb65688a
KAFKA-4050; Allow configuration of the PRNG used for SSL
Add an optional configuration for the SecureRandom PRNG implementation, with
the default behavior being the same (use the default implementation in the
JDK/JR
Repository: kafka
Updated Branches:
refs/heads/trunk 79d3fd2bf -> 104d2154b
KAFKA-4050; Allow configuration of the PRNG used for SSL
Add an optional configuration for the SecureRandom PRNG implementation, with
the default behavior being the same (use the default implementation in the
JDK/JRE
Repository: kafka
Updated Branches:
refs/heads/trunk 764d8ca9e -> 02d4da5f6
KAFKA-2960 KAFKA-1148; Clear purgatory for partitions before becoming follower
Author: Jiangjie Qin
Reviewers: Aditya Auradkar , Ismael Juma
, Joel Koshy , Jun Rao
, Guozhang Wang
Closes #1018 from becketqin/KAFK
Repository: kafka
Updated Branches:
refs/heads/trunk f6e35dec9 -> 5afa16601
KAFKA-3197; Fix producer sending records out of order
This patch reuse max.in.flight.request.per.connection. When it equals to one,
we take it as user wants order protection. The current approach is make sure
there i
Repository: kafka
Updated Branches:
refs/heads/trunk d142f8294 -> 04585d99c
MINOR - remove unused imports in package kafka.utils
Author: zhuchen1018
Reviewers: Grant Henke , Joel Koshy
, Dong Lin
Closes #935 from zhuchen1018/minor-remove-unused-imports
Project: http://git-wip-us.apache.
Repository: kafka
Updated Branches:
refs/heads/0.9.0 23c69d62a -> bb643f83a
KAFKA-3088; Make client-id a nullable string and fix handling of invalid
requests.
â¦ith empty client ID
- Adds NULLABLE_STRING Type to the protocol
- Changes client_id in the REQUEST_HEADER to NULLABLE_STRING with
Repository: kafka
Updated Branches:
refs/heads/trunk 85599bc3e -> d7fc7cf61
KAFKA-3088; Make client-id a nullable string and fix handling of invalid
requests."
â¦ent ID
- Adds NULLABLE_STRING Type to the protocol
- Changes client_id in the REQUEST_HEADER to NULLABLE_STRING with a default o
Repository: kafka
Updated Branches:
refs/heads/0.9.0 c6ecc7809 -> c3f575d5f
KAFKA-3179; Fix seek on compressed messages
The fix itself is simple.
Some explanation on unit tests. Currently we the vast majority of unit test is
running with uncompressed messages. I was initially thinking about
Repository: kafka
Updated Branches:
refs/heads/trunk 7802a90ed -> db8d6f02c
KAFKA-3179; Fix seek on compressed messages
The fix itself is simple.
Some explanation on unit tests. Currently we the vast majority of unit test is
running with uncompressed messages. I was initially thinking about
Repository: kafka
Updated Branches:
refs/heads/trunk 42bcc4339 -> 0da654761
KAFKA-2663; Trivial follow-up to edit comments
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/0da65476
Tree: http://git-wip-us.apache.org/repos/a
Repository: kafka
Updated Branches:
refs/heads/trunk 1b5687b9e -> 217eb9044
KAFKA-2663 KAFKA-2664; Add quota-delay time to request processing time
break-up; avoid using copy-on-write map for metrics
This has 2 fixes:
KAFKA-2664 - This patch changes the underlying map implementation of
Metric
Repository: kafka
Updated Branches:
refs/heads/trunk 86eb74d92 -> 300565381
KAFKA-2454; Deadlock between log segment deletion and server shutdown.
Author: Jiangjie Qin
Reviewers: Joel Koshy
Closes #153 from becketqin/KAFKA-2454
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
C
Repository: kafka
Updated Branches:
refs/heads/trunk fe4818e09 -> 9fde92f9f
KAFKA-2443 KAFKA-2567; Expose windowSize on Rate; - Throttle time should not
return NaN
This is a followup ticket from KAFKA-2084 to improve the windowSize calculation
in Quotas. I've made the following changes:
1.
Repository: kafka
Updated Branches:
refs/heads/trunk 2047a9afe -> 118912e76
KAFKA-2419; Garbage collect unused sensors
As discussed in KAFKA-2419 - I've added a time based sensor retention config to
Sensor. Sensors that have not been "recorded" for 'n' seconds are eligible for
expiration.
I
Repository: kafka
Updated Branches:
refs/heads/trunk 5e769ccd5 -> d03b871dd
MINOR: Set `sendTime` in `doSend` instead of `InFlightRequests.add` and rename
method names for consistency
hachikuji MayureshGharat jjkoshy Thoughts?
Author: Ismael Juma
Reviewers: Mayuresh Gharat , Ja
Repository: kafka
Updated Branches:
refs/heads/trunk 73720113b -> f5596a851
HOTFIX: Checkstyle import fix
Author: Ismael Juma
Reviewers: Joel Koshy
Closes #261 from ijuma/checkstyle-import-fix
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org
Repository: kafka
Updated Branches:
refs/heads/trunk 4e7db3955 -> 2c4e63a89
http://git-wip-us.apache.org/repos/asf/kafka/blob/2c4e63a8/clients/src/test/java/org/apache/kafka/clients/producer/internals/RecordAccumulatorTest.java
---
KAFKA-2120; Add a request timeout to NetworkClient (KIP-19); reviewed by Jason
Gustafson, Ismael Juma, Joel Koshy, Jun Rao, and Edward Ribeiro
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/2c4e63a8
Tree: http://git-wip-us.a
Repository: kafka
Updated Branches:
refs/heads/trunk da39931af -> 9dbeb71ab
http://git-wip-us.apache.org/repos/asf/kafka/blob/9dbeb71a/clients/src/test/java/org/apache/kafka/clients/producer/internals/RecordAccumulatorTest.java
---
Revert "KAFKA-2120; Add a request timeout to NetworkClient (KIP-19); reviewed
by Jason Gustafson, Ismael Juma, Joel Koshy, Jun Rao, and Edward Ribeiro"
This reverts commit da39931afad8008bc2b385a75a462777be051435.
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip
KAFKA-2120; Add a request timeout to NetworkClient (KIP-19); reviewed by Jason
Gustafson, Ismael Juma, Joel Koshy, Jun Rao, and Edward Ribeiro
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/da39931a
Tree: http://git-wip-us.a
Repository: kafka
Updated Branches:
refs/heads/trunk b658e2520 -> da39931af
http://git-wip-us.apache.org/repos/asf/kafka/blob/da39931a/clients/src/test/java/org/apache/kafka/clients/producer/internals/RecordAccumulatorTest.java
---
Repository: kafka
Updated Branches:
refs/heads/trunk 6f398d63a -> 9223155e9
KAFKA-2437; Trivial follow-up
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/9223155e
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/922
Repository: kafka
Updated Branches:
refs/heads/trunk 689d170ac -> 6f398d63a
KAFKA-2437; Fix ZookeeperLeaderElector to handle node deletion correctly.
Author: Jiangjie Qin
Reviewers: Joel Koshy
Closes #189 from becketqin/KAFKA-2437
Project: http://git-wip-us.apache.org/repos/asf/kafka/rep
Repository: kafka
Updated Branches:
refs/heads/trunk 13c432f79 -> e582447ad
KAFKA-2332; Add quota metrics to old producer and consumer
Author: Dong Lin
Reviewers: Aditya Auradkar , Joel Koshy
, Jiangjie Qin
Closes #176 from lindong28/KAFKA-2332
Project: http://git-wip-us.apache.org/repo
Repository: kafka
Updated Branches:
refs/heads/trunk 5d453ba6d -> 436b7ddc3
KAFKA-2136; Add throttle time (on quota violation) in fetch/produce
responses; reviewed by Joel Koshy, Dong Lin and Jun Rao
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.o
Repository: kafka
Updated Branches:
refs/heads/trunk 1d2ae89c5 -> 5d453ba6d
KAFKA-2351; Catch all exceptions in socket server's acceptor; reviewed by Grant
Henke, Joel Koshy, Jiangjie Qin, Jun Rao
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org
Repository: kafka
Updated Branches:
refs/heads/trunk 767a8a762 -> 9a6b57334
KAFKA-1901; Move Kafka version to be generated in code by build (instead of in
manifest); reviewed by Ismael Juma, Joel Koshy, Jason Rosenberg
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http:/
Repository: kafka
Updated Branches:
refs/heads/trunk 47b7a686e -> 0b04f9f34
KAFKA-2246; Fix incorrect config ZK path.
This bug was introduced while committing KAFKA-2205. Basically, the path for
topic overrides was renamed to "topic" from "topics". However, this causes
existing topic config
Repository: kafka
Updated Branches:
refs/heads/trunk 9e2c683f5 -> 47b7a686e
KAFKA-2084; trivial follow-up (remove JUnit3Suite dependency)
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/47b7a686
Tree: http://git-wip-us.apa
Repository: kafka
Updated Branches:
refs/heads/trunk f6acfb089 -> bbb7d97ad
KAFKA-2084; Add per-client-id byte-rate metrics and quota manager; reviewed by
Joel Koshy, Dong Lin, Jun Rao and Edward Ribeiro
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apa
Repository: kafka
Updated Branches:
refs/heads/0.8.2.20-hotfix-LIKAFKA-3427-offset-fetch-incompatibility
[deleted] a098de48e
Repository: kafka
Updated Branches:
refs/heads/hotfix [deleted] a098de48e
Repository: kafka
Updated Branches:
refs/heads/0.8.2.20-hotfix-LIKAFKA-3427-offset-fetch-incompatibility
[created] a098de48e
Repository: kafka
Updated Branches:
refs/heads/hotfix [created] a098de48e
Hot fix for LIKAFKA-3492; force offset commit/fetches to go to kafka regardless
of request version
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/
Repository: kafka
Updated Branches:
refs/heads/trunk 9ca61d179 -> 4aba4bc1d
Trivial commit - explicitly exclude build/** from rat check
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/4aba4bc1
Tree: http://git-wip-us.apach
Repository: kafka
Updated Branches:
refs/heads/trunk 23d72bccb -> 4204f4a06
Trivial commit - explicitly exclude build/rat-report.xml from rat check
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/4204f4a0
Tree: http://git-
Repository: kafka
Updated Branches:
refs/heads/trunk f13dd8024 -> 23d72bccb
KAFKA-2298; Client Selector can drop connections on InvalidReceiveException
without notifying NetworkClient; reviewed by Jason Gustafson and Joel Koshy
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commi
Repository: kafka
Updated Branches:
refs/heads/trunk 1eac3ceaf -> 2270a7537
KAFKA-2293; Fix incorrect format specification in Partition.scala; reviewed by
Joel Koshy
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/2270a75
Repository: kafka
Updated Branches:
refs/heads/trunk dc54055d0 -> 1eac3ceaf
KAFKA-2245; Add response tests for consumer coordinator; reviewed by Joel Koshy
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/1eac3cea
Tree: htt
Repository: kafka
Updated Branches:
refs/heads/trunk 78ba492e3 -> ca6d01bc6
KAFKA-2246; UnknownTopicOrPartitionException should be an instance of
InvalidMetadataException; reviewed by Ewen Cheslack-Postava and Joel Koshy
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http
Repository: kafka
Updated Branches:
refs/heads/trunk 9e894aa01 -> 48edeca33
KAFKA-2161; Fix a few copyrights
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/48edeca3
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/
Repository: kafka
Updated Branches:
refs/heads/trunk c60f32501 -> d6c45c70f
KAFKA-2186; Follow-up to KAFKA-1650 - add selective offset commit to consumer
connector API; reviewed by Joel Koshy
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repo
KAFKA-2091; Expose a partitioner interface in the new producer
(https://cwiki.apache.org/confluence/display/KAFKA/KIP-+22+-+Expose+a+Partitioner+interface+in+the+new+producer);
reviewed by Joel Koshy and Jay Kreps
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-u
Repository: kafka
Updated Branches:
refs/heads/trunk 23ff851f3 -> 467736c7a
Revert "KAFKA-2186; Follow-up to KAFKA-1650 - add selective offset commit to"
This reverts commit 23ff851f30bb55e794aefd2fae5367845d9230ee.
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://gi
KAFKA-2186; Follow-up to KAFKA-1650 - add selective offset commit to
consumer connector API; reviewed by Joel Koshy
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/23ff851f
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tr
Repository: kafka
Updated Branches:
refs/heads/trunk bb133c63b -> 23ff851f3
KAFKA-2190; Flush mirror maker before commiting offsets; abort the
mirror-maker producer with close(0) on send error; reviewed by Joel
Koshy
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://gi
KAFKA-1660; Add API to the producer to support close with a timeout; reviewed
by Joel Koshy and Jay Kreps.
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/33af0cba
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/33af0
Repository: kafka
Updated Branches:
refs/heads/trunk af5061923 -> 33af0cba3
KAFKA-2175; Change INFO to DEBUG for socket close on no error; and partition
reassignment JSON; reviewed by Gwen Shapira and Joel Koshy
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wi
KAFKA-2163; The offsets manager's stale-offset-cleanup and offset load should
be mutually exclusive; reviewed by Jun Rao
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/2d5e0f07
Tree: http://git-wip-us.apache.org/repos/asf/ka
Repository: kafka
Updated Branches:
refs/heads/trunk 01e94e2b4 -> 2166104af
KAFKA-2138; Fix producer to honor retry backoff; reviewed by Joel Koshy and
Guozhang Wang
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/2166104
Author: jjkoshy
Date: Sat Apr 4 01:42:17 2015
New Revision: 1671238
URL: http://svn.apache.org/r1671238
Log:
KAFKA-1546; Update documentation for automated replica lag tuning; patched by
Aditya Auradkar; reviewed by Joel Koshy and Jun Rao
Modified:
kafka/site/083/design.html
kafka/site
Repository: kafka
Updated Branches:
refs/heads/trunk 48f997047 -> 15b93a410
KAFKA-1546; Automate replica lag tuning; reviewed by Joel Koshy, Neha
Narkhede, Jun Rao and Guozhang Wang
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka
Repository: kafka
Updated Branches:
refs/heads/trunk 151ae42cd -> 00c643e6f
KAFKA-1755; trivial follow-up to fix comment in CleanerTest
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/00c643e6
Tree: http://git-wip-us.apach
Repository: kafka
Updated Branches:
refs/heads/trunk 61f02fa54 -> 4c9ad9b8a
KAFKA-2001; Trivial commit to fix OffsetCommitTest
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/4c9ad9b8
Tree: http://git-wip-us.apache.org/rep
Repository: kafka
Updated Branches:
refs/heads/trunk 57d38f672 -> 61f02fa54
KAFKA-2001; Trivial commit to prevent OffsetCommitTest from hanging
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/61f02fa5
Tree: http://git-wip-
KAFKA-1986; Request failure rate should not include invalid message size and
offset out of range; reviewed by Joel Koshy
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/57d38f67
Tree: http://git-wip-us.apache.org/repos/asf/ka
Repository: kafka
Updated Branches:
refs/heads/trunk 1cd6ed9e2 -> 57d38f672
KAFKA-1852; Reject offset commits to unknown topics; reviewed by Joel Koshy
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/616987d1
Tree: http://
KAFKA-1499; trivial follow-up (remove unnecessary parentheses)
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/c5d654ac
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/c5d654ac
Diff: http://git-wip-us.apache.org/repos/
Repository: kafka
Updated Branches:
refs/heads/trunk 0636928d9 -> 1cd6ed9e2
KAFKA-1755; Reject compressed and unkeyed messages sent to compacted topics;
reviewed by Mayuresh Gharat, Neha Narkhede and Guozhang Wang
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-
Repository: kafka
Updated Branches:
refs/heads/trunk 10311c138 -> b8904e961
KAFKA-1953; KAFKA-1962; Disambiguate purgatory metrics; restore delayed request
metrics; reviewed by Guozhang Wang
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 f7f8ac1a8 -> 4c8817e3d
KAFKA-1729; (followup patch)Add constructor to javaapi to allow
constructing explicitly versioned offset fetch requests; reviewed by Jun Rao
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://gi
Repository: kafka
Updated Branches:
refs/heads/trunk 8d72816f4 -> f7f8ac1a8
KAFKA-1914; follow-up to fix SimpleFetchTest; reviewed by Joel Koshy
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/f7f8ac1a
Tree: http://git-wip
Repository: kafka
Updated Branches:
refs/heads/trunk f5684366e -> 8d72816f4
KAFKA-1914; follow-up to address unit test failure
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/8d72816f
Tree: http://git-wip-us.apache.org/rep
Repository: kafka
Updated Branches:
refs/heads/trunk cb40ec2e7 -> d5fbba633
KAFKA-1959; Rename group to groupId in TestOffsetManager due to collision with
Thread.group in IBM's JDK; reviewed by Joel Koshy and Gwen Shapira
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: htt
KAFKA-1960; .gitignore does not exclude test generated files and folders;
reviewed by Joel Koshy and Gwen Shapira
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/d5fbba63
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tre
KAFKA-1914; Include total produce/fetch stats in broker topic metrics.
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/cb40ec2e
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/cb40ec2e
Diff: http://git-wip-us.apache.or
Repository: kafka
Updated Branches:
refs/heads/trunk 5b949c7b1 -> cb40ec2e7
KAFKA-1943; MessageSizeTooLarge and MessageSetSizeTooLarge should not be
counted toward broker-side producer failure rate
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.or
Repository: kafka
Updated Branches:
refs/heads/trunk a3d6dcaf1 -> eab4f4c9f
KAFKA-1697; Remove support for producer ack > 1 on the broker; reviewed by Joel
Koshy
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/eab4f4c9
Tr
Author: jjkoshy
Date: Wed Feb 4 01:17:49 2015
New Revision: 1656966
URL: http://svn.apache.org/r1656966
Log:
KAFKA-1729; follow-up documentation patch on offset management
Modified:
kafka/site/082/implementation.html
Modified: kafka/site/082/implementation.html
URL:
http://svn.apache.org
Repository: kafka
Updated Branches:
refs/heads/trunk 75a286e43 -> f1ba4ff87
KAFKA-1729; Add constructor to javaapi to allow constructing explicitly
versioned offset commit requests; reviewed by Jun Rao
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apach
Author: jjkoshy
Date: Tue Feb 3 01:59:07 2015
New Revision: 1656620
URL: http://svn.apache.org/r1656620
Log:
KAFKA-1729; Add documentation for Kafka-based offset management; reviewed by
Jun Rao and Gwen Shapira.
Modified:
kafka/site/082/configuration.html
kafka/site/082
Repository: kafka
Updated Branches:
refs/heads/trunk 5d648cfdb -> fcc252185
KAFKA-1823; Fix transient failure in PartitionAssignorTest; reviewed by
Guozhang Wang and Neha Narkhede
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/
Repository: kafka
Updated Branches:
refs/heads/trunk 1c8f89bc7 -> 45697ed6c
KAFKA-1499; Trivial follow-up (fix comments and whitespace)
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/45697ed6
Tree: http://git-wip-us.apach
Repository: kafka
Updated Branches:
refs/heads/trunk a61117840 -> 1c8f89bc7
KAFKA-1499; Broker-side compression configuration; reviewed by Joel Koshy
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/1c8f89bc
Tree: http://gi
Repository: kafka
Updated Branches:
refs/heads/trunk 84521872d -> 10c6dec34
KAFKA-1650; (Follow-up patch) to support no data loss in mirror maker; reviewed
by Joel Koshy
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/10c
Repository: kafka
Updated Branches:
refs/heads/0.8.2 91f8ce7ef -> de6d4e4f0
KAFKA-1764; ZookeeperConsumerConnector should not put multiple shutdown
commands to the same data chunk queue; reviewed by Joel Koshy and Guozhang Wang
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commi
Repository: kafka
Updated Branches:
refs/heads/trunk 8c35030e4 -> ca2cf97a6
KAFKA-1764; ZookeeperConsumerConnector should not put multiple shutdown
commands to the same data chunk queue; reviewed by Joel Koshy and Guozhang Wang
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commi
Repository: kafka
Updated Branches:
refs/heads/trunk d99af88ea -> 8c35030e4
Revert "KAFKA-1764; ZookeeperConsumerConnector should not put multiple shutdown
commands to the same data chunk queue; reviewed by Joel Koshy and Guozhang Wang"
This reverts commit d99af88eafefbfd1c537a64f8107cd904134
Repository: kafka
Updated Branches:
refs/heads/trunk 2cd9ae745 -> d99af88ea
KAFKA-1764; ZookeeperConsumerConnector should not put multiple shutdown
commands to the same data chunk queue; reviewed by Joel Koshy and Guozhang Wang
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commi
Repository: kafka
Updated Branches:
refs/heads/trunk 53160bb07 -> 2cd9ae745
KAFKA-1762; Update max-inflight-requests doc-string in producer config to note
risk of reordering in the presence of retries
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache
Repository: kafka
Updated Branches:
refs/heads/0.8.2 80eb04f99 -> 383ac3e19
KAFKA-1742; ControllerContext removeTopic does not correctly update state;
reviewed by Joel Koshy, Guozhang Wang and Neha Narkhede
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.
Repository: kafka
Updated Branches:
refs/heads/trunk 9b3da9fbf -> 53160bb07
KAFKA-1742; ControllerContext removeTopic does not correctly update state;
reviewed by Joel Koshy, Guozhang Wang and Neha Narkhede
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.
Repository: kafka
Updated Branches:
refs/heads/trunk 58e3f99e2 -> 4bb020212
KAFKA-1706; Add a byte bounded blocking queue utility; reviewed by Joel Koshy
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/4bb02021
Tree: http:
Repository: kafka
Updated Branches:
refs/heads/0.8.2 9be9a80d0 -> 2ec356fa9
KAFKA-1647; Create replicas on follower transition even if leader is
unavailable, otherwise replication offset checkpoints (high water marks)
can be lost on hard kills and restarts; reviewed by Joel Koshy, Neha
Narkhede
Repository: kafka
Updated Branches:
refs/heads/trunk 89831204c -> 1ed9cf6d0
KAFKA-1647; Create replicas on follower transition even if leader is
unavailable, otherwise replication offset checkpoints (high water marks)
can be lost on hard kills and restarts; reviewed by Joel Koshy, Neha
Narkhede
Repository: kafka
Updated Branches:
refs/heads/trunk 20f5b01fe -> 89831204c
http://git-wip-us.apache.org/repos/asf/kafka/blob/89831204/core/src/main/scala/kafka/server/ReplicaManager.scala
--
diff --git a/core/src/main/scala/ka
1 - 100 of 200 matches
Mail list logo
