src-kafka

Commit Graph

Author	SHA1	Message	Date
Rajini Sivaram	f4101ab3fc	KAFKA-2089: Fix transient MetadataTest failure; reviewed by Jiangjie Qin and Guozhang Wang	10 years ago
Ashish Singh	594b963930	KAFKA-2275: Add ListTopics() API to the Java consumer; reviewed by Jason Gustafson, Edward Ribeiro and Guozhang Wang	10 years ago
Ashish Singh	3df46bf4ce	KAFKA-2347: Add setConsumerRebalanceListener method to ZookeeperConsumerConnector java api; reviewed by Jiangjie Qin, Ismael Juma, Grant Henke and Guozhang Wang	10 years ago
Ashish Singh	269c2407d4	KAFKA-2381: Fix concurrent modification on assigned partition while looping over it; reviewed by Jason Gustafson, Aditya Auradkar, Ewen Cheslack-Postava, Ismael Juma and Guozhang Wang	10 years ago
Ashish Singh	57386de645	KAFKA-2301: Warn ConsumerOffsetChecker as deprecated; reviewed by Ewen Cheslack-Postava and Guozhang Wang	10 years ago
Ismael Juma	4389a11f68	KAFKA-2321; Introduce CONTRIBUTING.md Author: Ismael Juma <ismael@juma.me.uk> Reviewers: Guozhang Closes #97 from ijuma/kafka-2321 and squashes the following commits: `4834464` [Ismael Juma] KAFKA-2321; Introduce CONTRIBUTING.md	10 years ago
Ismael Juma	fd3a3cd595	KAFKA-2348; Drop support for Scala 2.9 `testAll` passed locally. Author: Ismael Juma <ismael@juma.me.uk> Reviewers: Harsha, Ewen, Guozhang Closes #87 from ijuma/kafka-2348-drop-support-for-scala-2.9 and squashes the following commits: `cf9796a` [Ismael Juma] KAFKA-2348; Drop support for Scala 2.9	10 years ago
Guozhang Wang	520a8135f4	KAFKA-2353; SocketServer catch exception and close connection properly; reviewed by Gwen Shapira, Ismael Juma and Guozhang Wang	10 years ago
Edward Ribeiro	66c8647d85	KAFKA-2355; Add an unit test to validate the deletion of a partition marked as deleted; patched by Edward Ribeiro, reviewed by Ashish Singh, Ismael Juma and Grant Henke	10 years ago
Ismael Juma	18adec7ed5	KAFKA-2344; kafka-merge-pr improvements The first 4 commits are adapted from changes that have been done to the Spark version and the last one is the feature that gwenshap asked for. Author: Ismael Juma <ismael@juma.me.uk> Reviewers: Gwen Shapira <cshapi@gmail.com> Closes #90 from ijuma/kafka-2344-merge-pr-improvements and squashes the following commits: `900c371` [Ismael Juma] Allow reviewers to be entered during merge `ac06347` [Ismael Juma] Allow primary author to be overridden during merge `b309829` [Ismael Juma] Set JIRA resolution to "Fixed" instead of relying on default transition `0c69a64` [Ismael Juma] Check return value of doctest.testmod() `061cdce` [Ismael Juma] Fix instructions on how to install the `jira-python` library	10 years ago
Jason Gustafson	fd3b4cc41e	KAFKA-2342; KafkaConsumer rebalance with in-flight fetch can cause invalid position Author: Jason Gustafson <jason@confluent.io> Closes #88 from hachikuji/KAFKA-2342 and squashes the following commits: `cabb017` [Jason Gustafson] KAFKA-2342; KafkaConsumer rebalance with in-flight fetch can cause invalid position	10 years ago
Ismael Juma	2040890462	KAFKA-2328; merge-kafka-pr.py script should not leave user in a detached branch The right command to get the branch name is `git rev-parse --abbrev-ref HEAD` instead of `git rev-parse HEAD`. The latter gives the commit hash causing a detached branch when we checkout to it. Seems like a bug we inherited from the Spark script. Author: Ismael Juma <ismael@juma.me.uk> Closes #84 from ijuma/kafka-2328-merge-script-no-detached-branch and squashes the following commits: `ae201dd` [Ismael Juma] KAFKA-2328; merge-kafka-pr.py script should not leave user in a detached branch	10 years ago
Grant Henke	1d2bd6284b	KAFKA-2337; Verify that metric names will not collide when creating new topics; patched by Grant Henke; reviewed by Edward Ribeiro, Ashish Singh and Gwen Shapira	10 years ago
Gwen Shapira	8463627242	Adding a file missed while committing KAFKA-2345	10 years ago
Ashish Singh	a5b11886df	KAFKA-2345; Attempt to delete a topic already marked for deletion throws ZkNodeExistsException; patched by Ashish Singh; reviewed by Sriharsha Chintalapani and Ismael Juma	10 years ago
Ismael Juma	15cba9f00d	KAFKA-2324; Update to Scala 2.11.7 Author: Ismael Juma <ismael@juma.me.uk> Closes #82 from ijuma/kafka-2324 and squashes the following commits: `d71bf5c` [Ismael Juma] KAFKA-2324; Update to Scala 2.11.7	10 years ago
Ewen Cheslack-Postava	31f621716e	kafka-2103; kafka.producer.AsyncProducerTest failure; patched by Ewen Cheslack-Postava; reviewed by Jun Rao	10 years ago
Jason Gustafson	5033b9613e	kafka-2271; transient unit test failure in KafkaConfigConfigDefTest.testFromPropsToProps; patched by Jason Gustafson; reviewed by Jun Rao	10 years ago
Alexey Ozeritskiy	1e0ed7a592	kafka-2174; Wrong TopicMetadata deserialization; patched by Alexey Ozeritskiy; reviewed by Jun Rao	10 years ago
Dong Lin	8fa24a6171	kafka-2241; AbstractFetcherThread.shutdown() should not block on ReadableByteChannel.read(buffer); patched by Dong Lin; reviewed by Jun Rao	10 years ago
Ismael Juma	458ebeb04b	kafka-2323; Simplify ScalaTest dependency versions; patched by Ismael Juma; reviewed by Jun Rao	10 years ago
Parth Brahmbhatt	fa03a7c6c4	KAFKA-2032: validate consumer's partition-assignment config; reviewed by Jason Rosenberg, Sriharsha Chintalapani and Guozhang Wang	10 years ago
Jason Gustafson	83d17e5b24	[MINOR] fix new consumer heartbeat reschedule bug This commit fixes a minor issue introduced in the patch for KAFKA-2123. The schedule method requires the time the task should be executed, not a delay. Author: Jason Gustafson <jason@confluent.io> Closes #79 from hachikuji/KAFKA-2123-fix and squashes the following commits: `6eb7ec6` [Jason Gustafson] [Minor] fix new consumer heartbeat reschedule bug	10 years ago
Jason Gustafson	4fcb7acafe	KAFKA-2335; fix comment about thread safety Author: Jason Gustafson <jason@confluent.io> Closes #78 from hachikuji/KAFKA-2335 and squashes the following commits: `c697998` [Jason Gustafson] KAFKA-2335; fix comment about consumer thread safety	10 years ago
Jason Gustafson	99c0686be2	KAFKA-2123: add callback in commit api and use a delayed queue for async requests; reviewed by Ewen Cheslack-Postava and Guozhang Wang	10 years ago
Manikumar Reddy	a7e0ac3659	KAFKA-2198: kafka-topics.sh exits with 0 status on failures; patched by Manikumar Reddy reviewed by Gwen Shapira	10 years ago
Ashish Singh	bdbb9672f5	kafka-972; MetadataRequest returns stale list of brokers; patched by Ashish Singh; reviewed by Jun Rao	10 years ago
Tim Brooks	69b451e289	KAFKA-2312: use atomic long for thread id reference; reviewed by Ewen Cheslack-Postava, Jason Gustafson, Ismael Juma and Guozhang Wang	10 years ago
Joel Koshy	4aba4bc1df	Trivial commit - explicitly exclude build/** from rat check	10 years ago
Jason Gustafson	9ca61d1791	KAFKA-1740 follow-up: add state checking in handling heartbeat request; reviewed by Onur Karaman, Ewen Cheslack-Postavam and Guozhang Wang	10 years ago
Geoff Anderson	ee88dbb67f	KAFKA-2327; broker doesn't start if config defines advertised.host but not advertised.port Added unit tests as well. These fail without the fix, but pass with the fix. Author: Geoff Anderson <geoff@confluent.io> Closes #73 from granders/KAFKA-2327 and squashes the following commits: `52a2085` [Geoff Anderson] Cleaned up unecessary toString calls `23b3340` [Geoff Anderson] Fixes KAFKA-2327	10 years ago
Sriharsha Chintalapani	7df39e0394	KAFKA-2316: Drop java 1.6 support; patched by Sriharsha Chintalapani reviewed by Ismael Juma and Gwen Shapira	10 years ago
Gwen Shapira	67b6b9a45b	KAFKA-2308: make MemoryRecords idempotent; reviewed by Guozhang Wang	10 years ago
Joel Koshy	4204f4a06b	Trivial commit - explicitly exclude build/rat-report.xml from rat check	10 years ago
Dong Lin	23d72bccbe	KAFKA-2298; Client Selector can drop connections on InvalidReceiveException without notifying NetworkClient; reviewed by Jason Gustafson and Joel Koshy	10 years ago
Onur Karaman	f13dd8024d	KAFKA-2313: javadoc fix for KafkaConsumer deserialization; reviewed by Guozhang Wang	10 years ago
Ashish Singh	826276de1e	KAFKA-2317: follow-up of KAFKA1367; reviewed by Guozhang Wang	10 years ago
Dong Lin	a99f70feb2	KAFKA-2306: add another metric for buffer exhausted; reviewed by Guozhang Wang	10 years ago
Joe Stein	ad485e148d	KAFKA-2304 Supported enabling JMX in Kafka Vagrantfile patch by Stevo Slavic reviewed by Ewen Cheslack-Postava	10 years ago
Ashish Singh	f77dc386c0	kafka-1367; Broker topic metadata not kept in sync with ZooKeeper; patched by Ashish Singh; reviewed by Jun Rao	10 years ago
Kostya Golikov	271b18d119	KAFKA-2314: proper MirrorMaker's message handler help message; reviewed by Guozhang Wang	10 years ago
Ashish Singh	2d96da05a0	kafka-2132; Move Log4J appender to a separate module; patched by Ashish Singh; reviewed by Gwen Shapira, Aditya Auradkar and Jun Rao	10 years ago
Ewen Cheslack-Postava	fd612a2d50	kafka-2248; Use Apache Rat to enforce copyright headers; patched by Ewen Cheslack-Postava; reviewed by Gwen Shapira, Joel Joshy and Jun Rao	10 years ago
Guozhang Wang	3f8480ccfb	KAFKA-1740: merge offset manager into consumer coordinator; reviewed by Onur Karaman and Jason Gustafson	10 years ago
Jason Gustafson	14e0ce0a47	KAFKA-2168: minor follow-up patch; reviewed by Guozhang Wang	10 years ago
Tao Xiao	9ff5b27bc5	KAFKA-2281: avoid unnecessary value copying if logAsString is false; reviewed by Guozhang Wang	10 years ago
Jeff Maxwell	6d4991e312	KAFKA-2294; javadoc compile error due to illegal <p/> , build failing (jdk 8); patched by Jeff Maxwell; reviewed by Jakob Homan	10 years ago
Jason Gustafson	b6d326b089	kafka-2168; New consumer poll() can block other calls like position(), commit(), and close() indefinitely; patched by Jason Gustafson; reviewed by Jay Kreps, Ewen Cheslack-Postava, Guozhang Wang and Jun Rao	10 years ago
Aditya Auradkar	2270a7537f	KAFKA-2293; Fix incorrect format specification in Partition.scala; reviewed by Joel Koshy	10 years ago
Onur Karaman	1eac3ceaf9	KAFKA-2245; Add response tests for consumer coordinator; reviewed by Joel Koshy	10 years ago

1 2 3 4 5 ...

1350 Commits (f4101ab3fcf7ec65f6541b157f1894ffdc8d861d) All Branches Search

1350 Commits (f4101ab3fcf7ec65f6541b157f1894ffdc8d861d)

All Branches