Neha Narkhede
|
10fa20001d
|
KAFKA-1185 Improve leader elector module to have a resign API; reviewed by Guozhang Wang and Jun Rao
|
11 years ago |
Sriram Subramanian
|
b23cf1968f
|
KAFKA-930 leader auto rebalance feature; reviewed by Neha Narkhede, Jun Rao and Guozhang Wang
|
11 years ago |
|
Sriram Subramanian
|
72610d1fc0
|
Merge branch 'trunk' of http://git-wip-us.apache.org/repos/asf/kafka into trunk
|
11 years ago |
|
Sriram Subramanian
|
e88f1acdaa
|
some more changes
|
11 years ago |
|
Sriram Subramanian
|
425af9b4a7
|
use zk for auto rebalance
|
11 years ago |
|
Neha Narkhede
|
b5d16871c0
|
KAFKA-1139 Topic data change handling callback should not call syncedRebalance directly; reviewed by Guozhang Wang and Jun Rao
|
11 years ago |
|
Neha Narkhede
|
dd58d753ce
|
KAFKA-1134 onControllerFailover function should be synchronized with other functions; reviewed by Neha Narkhede
|
11 years ago |
|
Neha Narkhede
|
169a79e687
|
KAFKA-1142 Patch review tool should take diff with origin from last divergent point; reviewed by Neha Narkhede
|
11 years ago |
|
Neha Narkhede
|
6bc290f66d
|
KAFKA-1178 Replica fetcher thread dies while becoming follower; reviewed by Jun Rao and Guozhang Wang
|
11 years ago |
|
Sriram Subramanian
|
55d77c67c2
|
Address code review feedbacks
|
11 years ago |
|
Neha Narkhede
|
32aae7202c
|
KAFKA-1170 ISR can be inconsistent during partition reassignment for low throughput partitions; reviewed by Jun Rao and Guozhang Wang
|
11 years ago |
|
Neha Narkhede
|
876cfdb597
|
KAFKA-1167 Improve the kafka-topics tool to list the topics with overridden configs; reviewed by Jun Rao
|
11 years ago |
Jun Rao
|
7dee06ee99
|
kafka-1169; missing synchronization in access to leaderCache in KafkaApis; patched by Jun Rao; reviewed by Neha Narkhede
|
11 years ago |
|
Jun Rao
|
8a2ba3f6f2
|
kafka-1168; OfflinePartitionCount in JMX can be incorrect during controlled shutdown; patched by Jun Rao; reviewed by Swapnil Ghike
|
11 years ago |
Swapnil Ghike
|
6c36beef87
|
minor fix for KAFKA-1152; ReplicaManager's handling of the leaderAndIsrRequest should gracefully handle leader == -1; patched by Swapnil Ghike; reviewed by Jun Rao
|
11 years ago |
|
Neha Narkhede
|
ea3961fc84
|
KAFKA-1156 Improve reassignment tool to output the existing assignment to facilitate rollbacks; reviewed by Jun Rao
|
11 years ago |
Guozhang Wang
|
b638b0f346
|
kafka-1157; Clean up Per-topic Configuration from Kafka properties; patched by Guozhang Wang; reviewed by Jun Rao
|
11 years ago |
|
Jun Rao
|
7c7951426d
|
kafka-1154; replicas may not have consistent data after becoming follower; patched by Jun Rao; reviewed by Guozhang Wang and Neha Narkhede
|
11 years ago |
|
Swapnil Ghike
|
224f192c77
|
kafka-1152; ReplicaManager's handling of the leaderAndIsrRequest should gracefully handle leader == -1; patched by Swapnil Ghike; reviewed by Jun Rao
|
11 years ago |
|
Guozhang Wang
|
df288b75a0
|
kafka-1140; Move the decoding logic from ConsumerIterator.makeNext to next; patched by Guozhang Wang; reviewed by Jun Rao
|
11 years ago |
Joel Koshy
|
ac239da502
|
Update description of num.partitions config in sample server properties - issue reported by Vaibhav Puranik
|
11 years ago |
|
Jun Rao
|
583044cd51
|
recommit kafka-1112 since it's inadvently reverted in the commit of kafka-1135
|
11 years ago |
Joe Stein
|
bb2dc49bde
|
KAFKA-1133 LICENSE and NOTICE files need to get into META-INF when jars are built before they're signed for publishing to maven reviewed by Joel Koshy
|
11 years ago |
|
Guozhang Wang
|
87efda7f81
|
kafka-1103; Consumer uses two zkclients; patched by Guozhang Wang; reviewed by Joel Koshy and Jun Rao
|
11 years ago |
Jie Huang
|
2477a7468e
|
kafka-1136; Add subAppend in Log4jAppender for generic usage; patched by Jie Huang; reviewed by Joel Koshy and Jun Rao
|
11 years ago |
drunkedcat
|
99dd94c9b6
|
kafka-933; Hadoop example running DataGenerator causes kafka.message.Message cannot be cast to [B exception; patched by drunkedcat; reviewed by Jun Rao
|
11 years ago |
|
Sriram Subramanian
|
7f32a1c276
|
Merge branch 'trunk' of http://git-wip-us.apache.org/repos/asf/kafka into trunk
|
11 years ago |
|
Jun Rao
|
cd81d37ac8
|
fix for scala 2.10.1 compilation issued introduced in kafka-1117
|
11 years ago |
|
Joe Stein
|
c2dd071b52
|
KAFKA-1131 copy license and notice to the release files, reviewed by David Arthur
|
11 years ago |
|
Swapnil Ghike
|
9b0776d157
|
kafka-1135; Code cleanup - use Json.encode() to write json data to zk; patched by Swapnil Ghike; reviewed by Neha Narkhede, Guozhang Wang and Jun Rao
|
11 years ago |
|
Jun Rao
|
440e45e513
|
kafka-1117; tool for checking the consistency among replicas; patched by Jun Rao; reviewed by Neha Narkhede, Joel Koshy, Swapnil Ghike, Guozhang Wang
|
11 years ago |
|
Sriram Subramanian
|
033872b316
|
commit missing code
|
11 years ago |
|
Sriram Subramanian
|
a4cd17a37b
|
some more changes
|
11 years ago |
|
Sriram Subramanian
|
09e807bda1
|
fix merge conflicts
|
11 years ago |
|
Sriram Subramanian
|
5bcb41835f
|
Add auto leader rebalance support
|
11 years ago |
|
Sriram Subramanian
|
39c5b75c96
|
Merge branch 'trunk' of http://git-wip-us.apache.org/repos/asf/kafka into trunk
|
11 years ago |
|
Jun Rao
|
58789d7cbe
|
kafka-1127; kafka and zookeeper server should start in daemon mode and log to correct position; patched by Raymond Liu; reviewed by Jun Rao
|
11 years ago |
|
Jun Rao
|
7c54e39bd4
|
KAFKA-1112; broker can not start itself after kafka is killed with -9; patched by Jay Kreps and Jun Rao; reviewed by Jay Kreps, Neha Narkhede and Guozhang Wang
|
11 years ago |
|
Sriram Subramanian
|
793b60763c
|
Merge branch 'trunk' of http://git-wip-us.apache.org/repos/asf/kafka into trunk
Conflicts:
core/src/main/scala/kafka/admin/AdminUtils.scala
core/src/main/scala/kafka/admin/TopicCommand.scala
|
11 years ago |
|
Neha Narkhede
|
eedbea6526
|
KAFKA-1119 Kafka 0.8.1 overwrites previous per topic config changes; reviewed by Joel Koshy, Guozhang Wang, Swapnil Ghike, Jay Kreps
|
11 years ago |
|
Joe Stein
|
a700c99efd
|
KAFKA-1126 Remove the DISCLAIMER it is left over from incubation reviewed by Neha
|
11 years ago |
|
Swapnil Ghike
|
9861618864
|
KAFKA-1121 DumpLogSegments tool should print absolute file name to report inconsistencies; reviewed by Neha Narkhede and Guozhang Wang
|
11 years ago |
|
Neha Narkhede
|
7d1ac1d806
|
Minor logging improvement
|
11 years ago |
|
Neha Narkhede
|
df7f7a255b
|
KAFKA-1097 Race condition while reassigning low throughput partition leads to incorrect ISR information in zookeeper; reviewed by Jun Rao, Guozhang Wang
|
11 years ago |
|
Neha Narkhede
|
e602ed0582
|
KAFKA-1113 log.cleanup.interval.mins property should be renamed; Trivial patch, no review
|
11 years ago |
|
Neha Narkhede
|
a4fafefdb3
|
KAFKA-1107 Follow up review cleanup comments
|
11 years ago |
|
Neha Narkhede
|
ec547737de
|
KAFKA-1107 Broker unnecessarily recovers all logs when upgrading from 0.8 to 0.8.1; reviewed by Jay Kreps and Guozhang Wang
|
11 years ago |
Roger Hoover
|
a55ec0620f
|
kafka-1092; Add server config parameter to separate bind address and ZK hostname; patched by Roger Hoover; reviewed by Jun Rao
|
11 years ago |
|
Guozhang Wang
|
bf4dbd5ee3
|
KAFKA-1060 Break-down sendTime into responseQueueTime and the real sendTime; reviewed by Neha Narkhede and Jun Rao
|
11 years ago |
|
Guozhang Wang
|
bd49e4f3e7
|
KAFKA-1001; Handle follower transition in batch; patched by Guozhang Wang; reviewed by Jun Rao
|
11 years ago |
