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

430 Commits (5a275b077af41803e22e5ac53a1fe474c53116ff)
 

Author SHA1 Message Date
Joel Jacob Koshy 14b42f7956 getOffset Api should return different latest offset to non-follower and follower consumers. Also, implement a batched version of the getOffset Api. patched by Joel Koshy; reviewed by Jun Rao; KAFKA-501
12 years ago
Jun Rao 3310531d87 restrict topic names (reopened); patched by Swapnil Ghike; reviewed by Jun Rao; KAFKA-495
12 years ago
Jun Rao 1cf88bc6c5 Use getMetadata Api in ZookeeperConsumerConnector; patched by Yang Ye; reviewed by Jun Rao; KAFKA-473
12 years ago
Joe Stein 85d5edfa9c KAFKA-533 changes to NOTICE and LICENSE related to KAFKA-534 removing client libraries from repo
12 years ago
Joe Stein 9a4ef48ef1 KAFKA-534 remove client library directory
12 years ago
Jun Rao b5dc73219e System Test should remove the top level data log directory; patched by John Fung; reviewed by Jun Rao; KAFKA-526
12 years ago
Jun Rao 081f0d2353 migration tool from 0.7 to 0.8; patched by Yang Ye; reviewed by Jun Rao; kafka-327
12 years ago
Jun Rao 0f06136aa8 javaapi support for getTopoicMetaData; patched by Swapnil Ghike; reviewed by Jun Rao; KAFKA-500
12 years ago
Neha Narkhede 3889a3b34f KAFKA-499 Refactor controller; patched by Neha Narkhede; reviewed by Jun Rao
12 years ago
Jun Rao 13e606924f trivial fix to log topics in fetching metadata properly
12 years ago
Joel Jacob Koshy b688c3ba04 KAFKA-391 Refactor fetch/producer requests to use maps instead of several arrays; patched by Joel Koshy; reviewed by Jun Rao.
12 years ago
Jun Rao c8f7587072 log.truncateTo needs to handle targetOffset smaller than the lowest offset in the log ; patched by Swapnil Ghike; reviewed by Jun Rao; KAFKA-463
12 years ago
Neha Narkhede fb0f176131 KAFKA-449: Leader election test
12 years ago
Jun Rao e42c8d5f4e revisit broker config in 0.8; patched by Swapnil Ghike; reviewed by Jun Rao; KAFKA-325
12 years ago
Jun Rao 2bc65dab67 Improve Kafka internal metrics; patched by Jun Rao; reviewed by Joel Koshy and Neha Narkhede; KAFKA-203
12 years ago
Jun Rao de927e2948 Handle topic names with / on Kafka server (0.8 branch); patched by Swapnil Ghike; reviewed by Jay Kreps, Joel Koshy and Jun Rao; KAFKA-495
12 years ago
Jun Rao ea14ae8b7f Check max message size on server; patched by Swapnil Ghike; reviewed by Joel Koshy and Jun Rao; KAFKA-490
12 years ago
Jun Rao 082d9d3b5a trival fix to remove a 0 byte file
12 years ago
Jun Rao ba58c9a704 remove errorcode from ByteBufferMessageSet; patched by Swapnil Ghike; reviewed by Jay Kreps and Jun Rao; KAFKA-458
12 years ago
Neha Narkhede 22e4341ba9 KAFKA-498: Controller has race conditions and synchronization bugs; patched by Neha Narkhede; reviewed by Jun Rao
12 years ago
Prashanth Menon 87fa96e291 Expose different data to fetch requests from the follower replicas and consumer clients; patched by Prashanth Menon; reviewed by Jun Rao; KAFKA-376
12 years ago
Jun Rao 50792c8765 Transient failure in ProducerTest; patched by Jun Rao; reviewed by Neha Narkhede; kafka-471
12 years ago
Jun Rao 259b710694 Handle topic names with / on Kafka server; patched by Jun Rao; reviewed by Neha Narkhede; kafka-470
12 years ago
Neha Narkhede 4cea1de21a KAFKA-483 Improvements to the system testing framework; patched by John Fung; reviewed by Neha Narkhede
12 years ago
Neha Narkhede d4f3eff171 KAFKA-489 Add metrics collection and graphs to the system test framework; patched by Neha Narkhede; reviewed by Jun Rao and John Fung
12 years ago
Jun Rao e72ff0ee2a Add constructor for message which takes both byte array offset and length; patched by Graham Sanderson; reviewed by Jun Rao; KAFKA-393
12 years ago
Jun Rao a32d37f6d1 Log errors for unrecognized config options; patched by Jun Rao; reviewed by Jay Kreps; KAFKA-181
12 years ago
Jun Rao a74cdb61b1 Require values in Utils.getTopic* methods to be positive (0.8 branch); patched by Swapnil Ghike; reviewed by Jun Rao; KAFKA-481
12 years ago
Jun Rao 2f34eda87e Expose JMX operation to set logger level dynamically (0.8 branch); patched by Jun Rao; reviewed by Jay Kreps; KAFKA-429
12 years ago
Jun Rao 31b9d124d6 maintain HW correctly with only 1 replica in ISR; patched by Jun Rao; reviewed by Neha Narkhede; KAFKA-420
12 years ago
Jun Rao 2756b424a7 Time based log segment rollout (0.8 branch); patched by Swapnil Ghike; reviewed by Jun Rao, Neha Narkhede; KAFKA-475
12 years ago
Jun Rao 17283a377d Controller tests throw several zookeeper errors; patched by Yang Ye; reviewed by Jun Rao; KAFKA-416
12 years ago
Jun Rao 93e9dbd026 update leaderAndISR in ZK conditionally; patched by Yang Ye; reviewed by Jun Rao; KAFKA-428
12 years ago
Jun Rao 0d6a4dff09 TopicCount.constructTopicCount isn't thread-safe; patched by Jun Rao; reviewed by Joel Koshy and Neha Narkhede; kafka-379
12 years ago
Neha Narkhede 5861046d09 KAFKA-440 Regression/system test framework; patched by John Fung; reviewed by Neha Narkhede
12 years ago
Jun Rao 663d254433 refactor ReplicaManager; patched by Jun Rao; reviewed by Neha Narkhede; KAFKA-351
12 years ago
Jun Rao 7baccc6c33 remove support for format for magic byte 0 in 0.8; patched by Swapnil Ghike; reviewed by Jun Rao; KAFKA-461
12 years ago
Jun Rao 27aaebc874 Create a generic Kafka thread; patched by Yang Ye; reviewed by Jun Rao, Jay Kreps; KAFKA-56
12 years ago
Jun Rao be521175dc failed ERROR messages in LazyInitProducerTest; patched by Yang Ye; reviewed by Jun Rao; kafka-467
12 years ago
Jun Rao 12a3ccafa1 KafkaController NPE in SessionExpireListener; patched by Yang Ye; reviewed by Jun Rao, Neha Narkhede; KAFKA-464
12 years ago
Jun Rao 60735b7ad6 enforce broker.id to be a non-negative integer; patched by Swapnil Ghike; reviewed by Jun Rao, Neha Narkhede; KAFKA-424
12 years ago
Joel Jacob Koshy 190bd3ff71 KAFKA-385 Fix race condition between checkSatisfied and expire in RequestPurgatory; fixed constant expiration of follower fetch requests as checkSatisfied was not getting called; add metrics to the RequestPurgatory; add a KafkaTimer convenience class; patched by Joel Koshy; reviewed by Jun Rao and Jay Kreps.
12 years ago
Jun Rao 0fe89f7a49 KafkaController.RequestSendThread can throw exception on broker socket; patched by Yang Ye; reviewed by Jun Rao; KAFKA-459, KAFKA-460
12 years ago
Edward Jay Kreps 9eb99fde9a KAFKA-323 Add more parameters to the log4j appender. Patch by Jose Quinteiro.
12 years ago
Edward Jay Kreps 623e2b7e53 KAFKA-424. Fix command line usage description. Patch from Tommie.
12 years ago
Edward Jay Kreps d482531810 KAFKA-425 Wrong class name in scripts. Patch from Akira Kitada reviewed by Jay Kreps.
12 years ago
Edward Jay Kreps a8790784df KAFKA-439 Fix bad javadoc. Patch from Jim Plush. Reviewed and modified by Jay Kreps.
12 years ago
Jun Rao ee855fe1aa remove ZK dependency on producer; patched by Yang Ye; reviewed by Jun Rao; KAFKA-369
12 years ago
Neha Narkhede b995133387 Minor checkin to fix replication system test and jmx tool
12 years ago
Neha Narkhede 8ceec6eff0 KAFKA-380 Enhance single_host_multi_brokers test with failure to trigger leader re-election in replication; patched by John Fung; reviewed by Neha Narkhede, Jun Rao and Joel Koshy
12 years ago