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

164 Commits (e7efee02c10e2def27d6b301e2f926202dabb9ce)
 

Author SHA1 Message Date
Joel Jacob Koshy e7efee02c1 KAFKA-353 Tie producer-side ack with high watermark and progress of replicas; patched by Joel Koshy; reviewed by Jun Rao, Jay Kreps
13 years ago
Jun Rao cb5be0aff1 Consumer doesn't receive all data; patched by Jun Rao; reviewed by John Fung; KAFKA-372
13 years ago
Jun Rao 505cf9d618 using MultiFetch in the follower; patched by Jun Rao; reviewed by Joel Koshy and Neha Narkhede; KAFKA-339
13 years ago
Jun Rao 0efd609fe7 Exception java.util.NoSuchElementException: None.get appears inconsistently; patched by Jun Rao; reviewed by Joel Koshy; KAFKA-370
13 years ago
Joe Stein a16448b71e KAFKA-368 use the pig core jar from maven instead of distributing it patch by Joe Stein reviewed by Jun Rao and Neha Narkhede
13 years ago
Jun Rao 1a8511684c upgrade ZKClient to allow conditional updates in ZK; patched by Jun Rao; reviewed by Joel Koshy; KAFKA-337
13 years ago
Prashanth Menon eff68ce1d0 Create topic support (revisit based on v3 design); patched by Prashanth Menon; reviewed by Jun Rao; KAFKA-329
13 years ago
Joe Stein efdc57bc58 KAFKA-348 rebase branch from trunk patch by Jun Rao reviewed by Joe Stein
13 years ago
Joe Stein ebcf7fc10d KAFKA-365 change copyright in NOTICE to current year, reviewed by Jun Rao
13 years ago
Jun Rao 965edbbcd8 system test to validate consistency of replicas; patched by John Fung; reviewed by Jun Rao; KAFKA-341
13 years ago
Jun Rao 83c82a3ecc embedded controller; patched by Yang Ye; reviewed by Jun Rao; KAFKA-335
13 years ago
Jun Rao 7d3a782e50 trivial change to add some logging info in DefaultEventHandler
13 years ago
Jun Rao f99177766a Add admin RPC requests; clean up Response objects; patched by Yang Ye; reviewed by Jun Rao; KAFKA-349; KAFKA-336
13 years ago
Neha Narkhede c4a913e3c4 Minor checkin to remove an empty package
13 years ago
Neha Narkhede 045f4fdca4 KAFKA-46: Message replication feature without failures; patched by Neha Narkhede; reviewed by Jun Rao, Jay Kreps, Prashanth Menon
13 years ago
Joe Stein 822963bb9d KAFKA-348 merge trunk to branch 1239902:1310937 patch by Joe Stein reviewed by Jun Rao
13 years ago
Prashanth Menon 904708fae8 Fix retry logic for producers; patched by Prashanth Menon; reviewed by Jun Rao, Neha Narkhede; KAFKA-49
13 years ago
Jun Rao 23b422bc44 upgrade ZKClient to allow conditional updates in ZK; patched by Jun Rao; reviewed by Joel Koshy; KAFKA-337
13 years ago
Edward Jay Kreps 1bedde76c2 KAFKA-48 Patch to add "long poll" support to fetch requests.
13 years ago
Neha Narkhede d73355017a KAFKA-301 Implement broker startup procedure; patched by Neha Narkhede; reviewed by Jun Rao and Jay Kreps
13 years ago
Neha Narkhede 79a3b31f26 KAFKA-320 testZKSendWithDeadBroker fails intermittently due to ZKNodeExistsException; patched by nehanarkhede; reviewed by junrao and prashanth menon
13 years ago
Jun Rao a260bfacae SyncProducer does not correctly timeout; patched by Prashanth Menon; reviewed by Jun Rao, Neha Narkhede; KAFKA-305
13 years ago
Neha Narkhede fedb9d6c19 KAFKA-307 Refactor server code to reduce interdependencies; patched by nehanarkhede; reviewed by junrao
13 years ago
Neha Narkhede 854fb29c26 KAFKA-300 Leader election; patched by nehanarkhede; reviewed by junrao
13 years ago
Jun Rao 4dd7f95569 Add acknowledgement to the produce request; patched by Prashanth Menon; reviewed by Jun Rao; KAFKA-49
13 years ago
Joe Stein 88660999a8 KAFKA-240 missing producer response
13 years ago
Joe Stein f8042d5b39 KAFKA-240 ProducerRequest wire format protocol update and related changes
13 years ago
Neha Narkhede 9fd2d4ffdb KAFKA-239 Refactoring code to wire new ZK data structures and making partitions logical; patched by Neha Narkhede; reviewed by Jun Rao
13 years ago
Jun Rao 6e36047fae disable dup topic in consumer request; patched by Prashanth Menon; reviewed by Jun Rao; KAFKA-240
13 years ago
Jun Rao a5fb217293 new consumer request format; patched by Prashanth Menon; reviewed by Jun Rao and Jay Kreps; KAFKA-240
13 years ago
Jun Rao 21da30456f refactor the async producer; patched by Jun Rao; reviewed by Neha Narkhede; KAFKA-253
13 years ago
Neha Narkhede e3b529df80 Merging commits 1230840:1239902 from trunk
13 years ago
Neha Narkhede af0ceff79b KAFKA-238 getTopicMetadata API; patched by nehanarkhede; reviewed by junrao
13 years ago
Jun Rao e913a06533 trivial fix to make create topic script executable
13 years ago
Jun Rao ff668f4fc9 create/delete ZK path for a topic in an admin tool; patched by Jun Rao; reviewed by Neha Narkhede; KAFKA-237
13 years ago
Neha Narkhede cd91e6770b Checking in some files left from the last checkin for KAFKA-202
13 years ago
Neha Narkhede 60d88a3ac9 KAFKA-202 Make request processing in kafka asynchronous; patched by jaykreps; reviewed by junrao and nehanarkhede
13 years ago
Neha Narkhede 5706727937 Creating branch for kafka-0.8.0-incubating that will include all replication related changes
13 years ago
Neha Narkhede 6c43b4634e Minor fix in the broker failure test for clean shutdown of servers
13 years ago
Jun Rao 7bd3e169f1 trivial fix to make output of ConsumerOffsetChecker sorted
13 years ago
Neha Narkhede a3c742ef23 KAFKA-245 Pull zkclient jar from Maven; patched by pyritschard; reviewed by nehanarkhede
13 years ago
Neha Narkhede 7821f5b20f KAFKA 218 Upgrade to zookeeper 3.3.4; patched by pyritschard; reviewed by nehanarkhede
13 years ago
Neha Narkhede b0484eccf3 KAFKA-228 Reduce duplicate messages served by the kafka consumer for uncompressed topics; patched by nehanarkhede; reviewed by junrao
13 years ago
Jun Rao 66be5eedf3 Support configurable send / receive socket buffer size in server; patched by John Fung; reviewed by Jun Rao; KAFKA-200
13 years ago
Neha Narkhede 336410a777 KAFKA-227 Broker failure system test; patched by johnfung; reviewed by nehanarkhede
13 years ago
Jun Rao aac7668195 Make backoff time during consumer rebalance configurable; patched by Jun Rao; reviewed by Neha Narkhede; KAFKA-234
13 years ago
Jun Rao a7d4c2cf23 avoid logging stacktrace directly; patched by Jun Rao; reviewed by Neha Narkhede; KAFKA-231
13 years ago
Edward Jay Kreps 5eb4badfc9 KAFKA-229 Patch from Joe Stein. Log full exception stack trace instead of just message.
13 years ago
Jun Rao e5a4ec1806 SyncProducer connect may return failed connection on reconnect; patched by Jun Rao; reviewed by Neha Narkhede; KAFKA-226
13 years ago
Neha Narkhede 77da5f54d7 KAFKA-221 LICENSE and NOTICE problems in Kafka 0.7; patched by jakobhoman; reviewed by junrao and nehanarkhede
13 years ago