tchekai704
/
src-kafka
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity
721 Commits
52 Branches
226 Tags
413 MiB
Tree: 583044cd51
Branches Tags
${ item.name }
Create tag ${ searchTerm }
Create branch ${ searchTerm }
from '583044cd51'
${ noResults }
Commit Graph

721 Commits (583044cd5109cd060bdfc9e516f4c85d1d4e73a0)
 

Author SHA1 Message Date
Neha Narkhede dcbf0bf0b7 KAFKA-1068 OfflinePartitionCount metrics may be incorrect after the controller failover; reviewed by Neha Narkhede and Guozhang Wang
11 years ago
Joe Stein 56ada95762 KAFKA-939 sbt publish-local fails due to invalid javac flags passed to javadoc patch by Frank Grimes reviewed by Joe Stein
11 years ago
Sam Meder bb7b45cd5d kafka-946; Kafka Hadoop Consumer fails when verifying message checksum; patched by Sam Meder; reviewed by Jun Rao
11 years ago
Neha Narkhede 61b8b2bf81 KAFKA-1062 Reading topic metadata from zookeeper leads to incompatible ordering of partition list; reviewed by Neha and Guozhang
11 years ago
Neha Narkhede 8959690e96 KAFKA-1053 Kafka patch review tool that integrates JIRA and reviewboard; reviewed by Joel Koshy, Swapnil Ghike and Guozhang Wang
11 years ago
Neha Narkhede d6f95cf97a KAFKA-1053 Kafka patch review tool that integrates JIRA and reviewboard; reviewed by Joel Koshy, Swapnil Ghike and Guozhang Wang
11 years ago
Neha Narkhede c6ca971738 KAFKA-1030 Addition of partitions requires bouncing all the consumers of that topic; reviewed by Neha, Swapnil, Joel
11 years ago
Jay Kreps 9feef9fd60 Trivial commit: Fix whitespace in Utils.rm.
11 years ago
Jun Rao aebf746190 KAFKA-1038; fetch response should use empty messageset instead of null when handling errors; patched by Jun Rao; reviewed by Neha Narkhede
11 years ago
Guozhang Wang 0c1885b800 KAFKA-955 (followup patch) After a leader change, messages sent with ack=0 are lost; reviewed by Neha Narkhede and Jun Rao
11 years ago
Jun Rao 324936609f merge from 0.8 c12d2ea9e5 to trunk
11 years ago
Neha Narkhede fed901cad2 KAFKA-1046 New files
11 years ago
Christopher Freeman 8e554c4d2a KAFKA-1046 Added support for Scala 2.10 builds while maintaining compatibility with 2.8.x; reviewed by Neha and Jun
11 years ago
Jun Rao 75d95d9b07 merge from 0.8 da4512174b and resolve conflicts
11 years ago
Christopher Freeman c12d2ea9e5 KAFKA-1046 Added support for Scala 2.10 builds while maintaining compatibility with 2.8.x; reviewed by Neha and Jun
11 years ago
Rajasekar Elango da4512174b kafka-1035; Add message-send-max-retries and retry-backoff-ms options to console producer; patched by Rajasekar Elango; reviewed by Guaozhang Wang and Jun Rao
11 years ago
Jun Rao 20953b5255 kafka-937; delta patch; ConsumerFetcherThread can deadlock; patched by Jun Rao; reviewed by Joel Koshy
11 years ago
Guozhang Wang f89ddced1b KAFKA-955 After a leader change, messages sent with ack=0 are lost; reviewed by Jay Kreps, Neha Narkhede and Jun Rao
11 years ago
Jun Rao ea54700d57 Merge branch '0.8' of http://git-wip-us.apache.org/repos/asf/kafka into 0.8
11 years ago
Vladislav Pernin 51de7c55d2 kafka-1031; Little modification to the stop script to be able to kill the proper process; patched by Vladislav Pernin; reviewed by Jun Rao
11 years ago
Sriram Subramanian 39fc578d5d KAFKA-990 Fix ReassignPartitionCommand and improve usability; reviewed by Neha, Jun, Joel and Guozhang
11 years ago
Sam Meder 7640bee3d2 KAFKA-1029 Zookeeper leader election stuck in ephemeral node retry loop; reviewed by Neha and Guozhang
11 years ago
Swapnil Ghike d217f4cc27 kafka-1017; High number of open file handles in 0.8 producer; patched by Swapnil Ghike; reviewed by Neha Narkhede and Jun Rao
11 years ago
Guozhang Wang ff6292904a KAFKA-1009 DumpLogSegments tool should return error on non-existing files; reviewed by Neha Narkhede
11 years ago
Guozhang Wang ceb55cad58 kafka-649; patch v5; Cleanup log4j logging; patched by Guozhang Wang; reviewed by Jun Rao
11 years ago
Guozhang Wang 6849da0505 kafka-992; follow-up patch; Double Check on Broker Registration to Avoid False NodeExist Exception; patched by Guozhang Wang; reviewed by Neha Narkhede and Jun Rao
11 years ago
Sam Meder 7a9faa49ed kafka-1010; Concurrency issue in getCluster() causes rebalance failure and dead consumer; patched by Sam Meder; reviewed by Jun Rao
11 years ago
Guozhang Wang 1db824ed2f KAFKA-992 followup: Fix zookeeper de-registration bug for controller and consumer; reviewed by Neha Narkhede
11 years ago
Neha Narkhede 1d75e09313 Revert "KAFKA-992 follow up: Fix the zookeeper de-registration issue for controller and consumer; reviewed by Neha Narkhede"
11 years ago
Guozhang Wang 81c49bbdae KAFKA-992 follow up: Fix the zookeeper de-registration issue for controller and consumer; reviewed by Neha Narkhede
11 years ago
Swapnil Ghike e7a546b67c kafka-1003; ConsumerFetcherManager should pass clientId as metricsPrefix to AbstractFetcherManager; patched by Swapnil Ghike; reviewed by Jun Rao
11 years ago
Swapnil Ghike 9753d15ef1 KAFKA-999 Controlled shutdown never succeeds until the broker is killed; reviewed by Neha Narkhede
11 years ago
Jay Kreps df18fe13ad KAFKA-615 fsync asynchronous from log roll. Patch reviewed by Jun and Sriram.
11 years ago
Phil Hargett 1d6ad3d7d4 kafka-989; Race condition shutting down high-level consumer results in spinning background thread; patched by Phil Hargett; reviewed by Jun Rao
11 years ago
Neha Narkhede 7fbbb6666b KAFKA-992 follow up. Fix broken unit test
11 years ago
Jay Kreps 14af713252 Misc. minor house-keeping fixes: add reasonable GC settings, fix up README, fix up example configs, fix the logging for tools, use a log directory for logs instead of the root directory.
11 years ago
Guozhang Wang f3f8fa5c8c KAFKA-992 Double Check on Broker Registration to Avoid False NodeExist Exception; reviewed by Neha Narkhede and Swapnil Ghike
11 years ago
Jay Kreps 493a46613e KAFKA-985 integer overflow in log time configuration values. Patch from Frank Fejes.
11 years ago
Jay Kreps bdb2fdc646 KAFKA-995 Ensure that replica fetch size is > max message size on server.
11 years ago
Joel Koshy 81a9f6a682 KAFKA-915; Mirror maker system tests should wait for topics to be created. (This patch is a work-around until KAFKA-956 is resolved.); patched by John Fung; reviewed by Joel Koshy.
11 years ago
Jun Rao ed3e146cf4 Merge branch '0.8' of http://git-wip-us.apache.org/repos/asf/kafka into 0.8
11 years ago
Sam Meder 0c8aefc251 kafka-994; High level consumer doesn't throw an exception when the message it is trying to fetch exceeds the configured fetch size; patched by Sam Meder; reviewed by Jay Kreps and Jun Rao
11 years ago
Joel Koshy b6479e8adc KAFKA-991; Rename config queue size to queue bytes in hadoop producer; patched by Swapnil Ghike, reviewed by Joel Koshy.
11 years ago
Joel Koshy 8edd3e6302 KAFKA-991; Reduce the queue size in hadoop producer; patched by Swapnil Ghike, reviewed by Jay Kreps and Joel Koshy.
11 years ago
Jay Kreps d285e263bf KAFKA-925 Add a partition key that overrides the message's stored key. Patch reviewed by Joel.
11 years ago
Guozhang Wang 76d39052f7 kafka-959; DefaultEventHandler can send more produce requests than necesary; patched by Guozhanh Wang; reviewed by Jun Rao
11 years ago
Joel Koshy bc5620cbd2 KAFKA-983; Expose MirrorMaker cleanShutdown method. Patched by Swapnil Ghike.
11 years ago
Joel Koshy 5cf6a54664 KAFKA-957; MirrorMaker needs to preserve ordering for keyed messages from source cluster; patched by Guozhang Wang, reviewed by Joel Koshy
11 years ago
Swapnil Ghike 401d59199c KAFKA-987 Avoid checkpointing offsets in Kafka consumer that have not changed since the last commit; reviewed by Neha Narkhede
11 years ago
John Fung ce7d588055 kafka-883; System Test - update migration tool testsuite after 0.7 ProducerPerformance sends seq MessageID; patched by John Fung; reviewed by Jun Rao
11 years ago