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

479 Commits (ede85875a3aea5723baf82736cc71bb1a04a6102)
 

Author SHA1 Message Date
Joel Jacob Koshy 947ad072af Implement clean shutdown in replication; patched by Joel Koshy; reviewed by Jun Rao and Neha Narkhede; KAFKA-340
12 years ago
Jun Rao 9eb9e51011 produce/fetch remote time metric not set correctly when num.acks = 1; patched by Jun Rao; reviewed by Neha Narkhede; KAFKA-584
12 years ago
Jun Rao 4ef9166769 trivial fix to add the missing Logging class
12 years ago
Jun Rao adebb7d78a Add more test cases to System Test ; patched by John Fung; reviewed by Jun Rao; KAFKA-571
12 years ago
Jun Rao 0d9f7ffe4d provides windows batch script for starting Kafka/Zookeeper; patched by Antoine Vianey; reviewed by Jun Rao; kafka-581
12 years ago
Jun Rao 68d8f59045 remove connection timeout in SyncProducer; patched by Swapnil Ghike; reviewed by Jun Rao; kafka-579
12 years ago
Jun Rao 23bce10e77 Change MessageSet.sizeInBytes to Int; patched by Swapnil Ghike; reviewed by Jun Rao; kafka-556
12 years ago
Jun Rao 3deb6cd420 SimpleConsumer throws UnsupportedOperationException: empty.head; patched by Yang Ye; reviewed by Jun Rao; kafka-576
12 years ago
Jun Rao 2c66f5b701 system test testcase_0122 under replication fails due to large # of data loss; patched by Jun Rao; reviewed by Neha Narkhede; KAFKA-580
12 years ago
Neha Narkhede 1b7b43c6e1 KAFKA-541 Move to metrics csv reporter for system tests; patched by Yang Ye; reviewed by Neha, Jun and Joel
12 years ago
Jun Rao e35854062f System Test : Leader Failure Log Segment Checksum Mismatched When request-num-acks is 1; patched by Jun Rao; reviewed by John Fung, Joel Koshy and Neha Narkhede; KAFKA-573
12 years ago
Neha Narkhede 98f6407089 KAFKA-537 Expose clientId in ConsumerConfig and fix correlation id; patched by Yang Ye; reviewed by Neha Narkhede
12 years ago
Edward Jay Kreps d1a22b2e3b KAFKA-569 Split up utils package and do some cleanup. Patch reviewed by Neha.
12 years ago
Neha Narkhede 3015d0a447 KAFKA-43 Move leader to preferred replica; patched by Neha Narkhede; reviewed by Joel Koshy and Jun Rao
12 years ago
Neha Narkhede 669ae397f8 KAFKA-548 remove partition from ProducerRequestPartitionData and FetchResponsePartitionData; patched by Yang Ye; reviewed by Neha and Joel
12 years ago
Jun Rao c0fdcd305c Replication Data Loss in Mirror Maker Bouncing testcase; patched by Jun Rao; reviewed by Joel Koshy, John Fung and Neha Narkhede; kafka-567
12 years ago
Jun Rao 2b13581711 trival fix to remove 2 empty files
12 years ago
Neha Narkhede 3629f6f882 Changing kafka-server-stop.sh to use SIGTERM for Kafka server process termination. No review
12 years ago
Neha Narkhede dd44ec672a KAFKA-432 allow consumer to read from followers; patched by Yang Ye; reviewed by Neha and Jun
12 years ago
Edward Jay Kreps 97d434513f KAFKA-506 Hadoop consumer not advancing to next offset. No review.
12 years ago
Neha Narkhede eb06b93f97 KAFKA-510 Broker needs to know replication factor per partition; patched by Yang Ye; reviewed by Neha Narkhede, Jun Rao and Joel Koshy
12 years ago
Edward Jay Kreps 4324235183 KAFKA-557 Patch to avoid assigning offsets to Log.appends as part of replication. Reviewed by Neha.
12 years ago
Edward Jay Kreps aaa5d14e39 KAFKA-506 Misc. follow-up cleanups from Neha's review.
12 years ago
Neha Narkhede 93fdcfa0e2 KAFKA-42 part 2: new files
12 years ago
Neha Narkhede 23d7620442 KAFKA-42 Cluster expansion feature; patched by Neha; reviewed by Jun
12 years ago
Neha Narkhede a1698e2b70 Reverting KAFKA-42 since it accidentally contained changes to metrics package. Didn't catch it due to a stale sbt cache. It is better to redo the patch and then commit
12 years ago
Neha Narkhede 6d0042b4f4 KAFKA-42 Cluster expansion feature; patched by Neha Narkhede; reviewed by Jun Rao
12 years ago
Neha Narkhede 01a8b8d123 Reverting KAFKA-510, to be reapplied after addressing review comments and after KAFKA-42 is checked in
12 years ago
Jun Rao cdc6ca2c7b trival fix to make run_sanity.sh executable
12 years ago
Neha Narkhede 1b4d3c3061 KAFKA-502 Adding 30 more system tests, reviewed by Jun and Neha; patched by John Fung
12 years ago
Jun Rao 3c335bfbdc trival fix to kafka-563: KafkaScheduler shutdown in ZookeeperConsumerConnector should check for config.autocommit
12 years ago
Jun Rao 6ccdc40ae8 broker needs to know the replication factor per partition; patched by Yang Ye; reviewed by Jun Rao; kafka-510
12 years ago
Jun Rao a975113c0e confusing reference to zk.connect in config/producer.properties; patched by yazgoo; reviewed by Jun Rao; kafka-553
12 years ago
Edward Jay Kreps 5a33bfa9d4 KAFKA-543 Avoid sending duplicate topic names in TopicMetadataRequest. Reviewed by Neha.
12 years ago
Joel Jacob Koshy 2f41be0916 Fix wildcard consumption to work with greater than one stream; KAFKA-550; patched by Joel Koshy; reviewed by Jun Rao and Neha Narkhede.
12 years ago
Joel Jacob Koshy 542ac86313 Upgrade to metrics jar to 3.x to pick up csv reporter fixes; KAFKA-542; patched by Joel Koshy; reviewed by Neha Narkhede.
12 years ago
Edward Jay Kreps 3a525e0bfa KAFKA-504 Catching the wrong exception in the test for snappy compression, added check for SnappyException too. Trivial fix, no review.
12 years ago
Jun Rao d5df29b84f support changing host/port of a broker; patched by David Arthur; reviewed by Jun Rao; kafka-474
12 years ago
Edward Jay Kreps 452be9080e KAFKA-551 Remove the concept of immutable log segments--now all indexes and message sets are mutable. This allows truncating old segments. Review by Jun and Neha.
12 years ago
Jun Rao eed5983596 Replica.hw should be initialized to the smaller of checkedpointed HW and log end offset; patched by Yang Ye; reviewed by Jun Rao; KAFKA-539
12 years ago
Joel Jacob Koshy c85c01b6e4 ConsumerOffsetChecker now works with hostnames (in addition to IP) in the brokers/ids zk path; KAFKA-549; patched by Bob Cotton; reviewed by Joel Koshy
12 years ago
Edward Jay Kreps f64fd3dcba KAFKA-506 Move to logical offsets. Reviewed by Jun and Neha.
12 years ago
Joe Stein 3f1fbb1d07 KAFKA-508 split out partiondata from fetchresponse and producerrequest
12 years ago
Jun Rao c42726cdaf ProducerSendThread calls ListBuffer.size a whole bunch. That is a O(n) operation; patched by David Arthur; reviewed by Jun Rao; kafka-456
12 years ago
Jun Rao 3bb1c16691 log.append() should halt on IOException; patched by Jun Rao; reviewed by Jay Kreps; KAFKA-540
12 years ago
Joel Jacob Koshy db4e02f263 Replace numerical compression codes in config with something human readable; KAFKA-363; patched by David Arthur; reviewed by Joel Koshy
12 years ago
Jun Rao db78c35fc0 server should shut down on encountering invalid highwatermark file; patched by Yang Ye; reviewed by Jun Rao; kafka-509
12 years ago
Jun Rao 9623ae4de3 IndexOutOfBoundsException thrown by kafka.consumer.ConsumerFetcherThread; patched by Jun Rao; reviewed by Jay Kreps and Neha Narkhede; kafka-528
12 years ago
Joe Stein 77b511f696 KAFKA-538 missing apache license header in sbt and util.h
12 years ago
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