Skip to content
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
332 commits
Select commit Hold shift + click to select a range
fb92b3a
KAFKA-1317 KafkaServer 0.8.1 not responding to .shutdown() cleanly, p…
tnachen Mar 29, 2014
1d5bbc8
kafka-1320; Change compression.codec to compression.type in new produ…
Mar 31, 2014
f82ce33
KAFKA-1350 Fix excessive state change logging;reviewed by Jun,Joel,Gu…
nehanarkhede Apr 1, 2014
083b626
KAFKA-1341 Client Selector doesn't check connection id properly; revi…
tnachen Apr 1, 2014
bd784ae
kafka-1318; waiting for producer to stop is not reliable in system te…
junrao Apr 1, 2014
98952b3
KAFKA-1251 Further metric naming standardization.
jkreps Apr 1, 2014
4f23ed3
KAFKA-1327 Add log cleaner metrics.
jkreps Apr 1, 2014
3721821
kafka-1344; Kafka-console-producer.sh support snappy compression; pat…
edgefox Apr 2, 2014
640f3b0
KAFKA-1337 Rationalize the producer configs.
jkreps Mar 27, 2014
62fcaed
KAFKA-1355; Avoid sending all topic metadata on state changes. Review…
jjkoshy Apr 7, 2014
a840c73
kafka-1337 followup to fix system tests
nehanarkhede Apr 8, 2014
8f94bc3
KAFKA-1366 Multiple Unit Test failures with new producer; reviewed by…
Apr 8, 2014
0e1d853
KAFKA-1356 Topic metadata requests takes too long to process; reviewe…
tnachen Apr 8, 2014
69655d5
Trivial: update javadoc comment for KAFKA-1355
jjkoshy Apr 8, 2014
a39f2c1
kafka-1352; Reduce logging on the server; patched by Ivan Lyutovg; re…
edgefox Apr 9, 2014
33e07a6
kafka-1371; Ignore build output dirs; patched by Stevo Slavic; review…
sslavic Apr 9, 2014
de6066e
kafka-1370; Gradle startup script for Windows; patched by Stevo Slavi…
sslavic Apr 9, 2014
75d5f5b
kafka-1375; Formatting for in README.md is broken; patched by Stevo S…
sslavic Apr 9, 2014
8d15de8
KAFKA-1373; Set first dirty (uncompacted) offset to first offset of the
jjkoshy Apr 8, 2014
911ff52
kafka-1364; ReplicaManagerTest hard-codes log dir; patched by Guozhan…
Apr 9, 2014
47019a8
kafka-1376; transient test failure in UncleanLeaderElectionTest; patc…
junrao Apr 9, 2014
44ee6b7
kafka-1353;report capacity used by request thread pool and network th…
Apr 10, 2014
2d429e1
kafka-1337; follow-up patch to add broker list for new producer in sy…
Apr 11, 2014
a3a2cba
kafka-1363; testTopicConfigChangesDuringDeleteTopic hangs; patched by…
tnachen Apr 12, 2014
6bb616e
trivial change to add kafka doap project file
junrao Apr 12, 2014
05612ac
kafka-1377; transient unit test failure in LogOffsetTest; patched by …
junrao Apr 12, 2014
d37ca7f
kafka-1378; transient unit test failure in LogRecoveryTest; patched b…
junrao Apr 12, 2014
2bfd49b
kafka-1381; transient unit test failure in AddPartitionsTest; patched…
junrao Apr 12, 2014
4bd33e5
kafka-1210; Windows Bat files are not working properly; patched by St…
sslavic Apr 13, 2014
9a6f711
kafka-1390; TestUtils.waitUntilLeaderIsElectedOrChanged may wait long…
junrao Apr 15, 2014
ec075c5
KAFKA-1359: Ensure all topic/server metrics registered at once.
jkreps Apr 16, 2014
97f13ec
KAFKA-1323; Fix regression due to KAFKA-1315 (support for relative
jjkoshy Apr 15, 2014
b9351e0
KAFKA-1398 dynamic config changes are broken.
jkreps Apr 18, 2014
8b05215
KAFKA-1337: Fix incorrect producer configs after config renaming.
jkreps Apr 17, 2014
037c054
KAFKA-1362; Publish sources and javadoc jars; (also removed Scala 2.8…
jjkoshy Apr 18, 2014
89f040c
KAFKA-1398 Dynamic config follow-on-comments.
jkreps Apr 18, 2014
3af3efe
KAFKA-1327; Log cleaner metrics follow-up patch to reset dirtiest log…
jjkoshy Apr 22, 2014
ed68ba4
kafka-1411; remove unused test cases; patched by Jun Rao; reviewed by…
junrao Apr 22, 2014
caafc9d
kafka-1410; MetadataCache cleanup; patched by Jun Rao; reviewed by Ti…
junrao Apr 23, 2014
93af67c
kafka-1359; Followup on K1359: change nanoTime to currentTimeMillis i…
Apr 23, 2014
0efdfa6
kafka-1389; transient unit test failure in ProducerFailureHandlingTes…
junrao Apr 24, 2014
3ebbaae
kafka-1418; transient unit test failure in ProducerFailureHandlingTes…
junrao Apr 24, 2014
e69c613
kafka-1424; transient unit test failure in testSendWithDeadBroker; pa…
junrao Apr 25, 2014
0bd4c87
kafka-1409; oversized messages can slow down the brokers; patched by …
Apr 25, 2014
c9bb24f
kafka-1392; all TestUtiles.waitUntilTrue() should throw an exception …
junrao Apr 25, 2014
8a0314d
kafka-1395; fix unit tests in AutoOffsetResetTest; patched by Guozhan…
Apr 25, 2014
6315363
kafka-1424; (followup patch) transient unit test failure in testSendW…
junrao Apr 28, 2014
2f56664
kafka-1383; transient unit test failure in SocketServerTest; patched …
junrao Apr 28, 2014
bbb357c
KAFKA-1428 Ensure we close the file handle when reading the config.
jkreps Apr 28, 2014
3de97c7
kafka-1400; transient unit test failure in SocketServerTest; patched …
nehanarkhede Apr 29, 2014
6b4217d
kafka-1433; transient unit test failure in ZookeeperConsumerConnector…
junrao May 1, 2014
198c793
KAFKA-1425; Expose metric for LogStartOffset; reviewed by Joel Koshy …
May 1, 2014
0062d4c
kafka-1412; transient unit test failure in ProducerSendTest.testAutoC…
junrao May 1, 2014
fe18595
kafka-1146; toString() on KafkaStream gets stuck indefinitely; patche…
amalakar May 2, 2014
3f7a906
KAFKA-1432 Make num.producerThreads configurable on new MirrrorMaker;…
May 5, 2014
44c39c4
kafka-1397; delete topic is not working; patched by Timothy Chen; rev…
tnachen May 6, 2014
9b6bf40
kafka-1384; Log Broker state; patched by Timothy Chen; reviewed by Jo…
tnachen May 6, 2014
4fe5c46
kafka-1384; Log Broker state; followup commit to add the missing new …
tnachen May 7, 2014
2848a7a
KAFKA-1432 followup - Fixing the shutdown sequence furthermore; revie…
May 7, 2014
754dacb
kafka-1432; followup patch to enable new producer in system test; pa…
May 8, 2014
1d35cce
KAFKA-1442 RBTools post-review is deprecated; reviewed by Neha Narkhede
May 8, 2014
31e32b3
kafka-1396; fix transient unit test ProducerFailureHandlingTest.testB…
May 14, 2014
c179c45
KAFKA-1437; Consumer metadata response should include (empty) coordin…
jjkoshy May 6, 2014
b866c55
KAFKA-1431 ConsoleConsumer - Option to clean zk consumer path;reviewe…
nehanarkhede May 15, 2014
99f1073
KAFKA-1445 Send all partitions, regardless of how full, whenever we a…
jkreps May 15, 2014
8d454f3
KAFKA-1179 createMessageStreams() in javaapi.ZookeeperConsumerConnect…
May 16, 2014
b4c1089
kafka-1453; Add a channel queue jmx in Mirror Maker; patched by Guoz…
May 16, 2014
345c52e
kafka-1453 (follow-up); Add a channel queue jmx in Mirror Maker; pat…
May 16, 2014
bf7fb63
kafka-1453 (2nd follow-up); Add a channel queue jmx in Mirror Maker; …
May 16, 2014
c24740c
KAFKA-1328 New consumer APIs; reviewed by Jun Rao and Guozhang Wang
nehanarkhede May 20, 2014
bf83131
KAFKA-1328 follow up: Updated javadoc
nehanarkhede May 21, 2014
d0df33d
KAFKA-1298 Controlled shutdown tool doesn't seem to work out of the b…
May 21, 2014
52f1149
KAFKA-1446 Consumer metrics for rebalance; reviewed by Neha Narkhede …
May 22, 2014
547cced
KAFKA-1456 Add LZ4 and LZ4C as a compression codec patch by James Oli…
joestein May 26, 2014
01ea4eb
KAFKA-1444 kafka.javaapi.TopicMetadata and PartitionMetadata doesn't …
nehanarkhede May 27, 2014
0ccc1dc
KAFKA-1459 kafka.tools.ConsumerOffsetChecker throws NoNodeException; …
May 27, 2014
f8ea4ac
KAFKA-924. Specify console consumer properties via a single --propert…
May 27, 2014
e73e90e
trival fix to remove reference of sbt in README
junrao May 28, 2014
26eb127
KAFKA-1459 follow up minor patch
May 28, 2014
02311c0
KAFKA-1468 Misc. improvements from benchmarking.
jkreps Apr 22, 2014
3a048e8
kafka-924 (follow-up); Specify console consumer properties via a sing…
Jun 3, 2014
df449a2
kafka-1473; transient unit test failure in testRequestHandlingDuringD…
Jun 4, 2014
1363ed7
KAFKA-1438 Migrate client tools out of perf; reviewed by Neha Narkhede
Jun 5, 2014
ee4456a
KAFKA-1443 Add delete topic option to topic commands; reviewed by Neh…
tnachen Jun 6, 2014
d300717
KAFKA-1469 Util.abs function does not return correct absolute values …
sgeller Jun 6, 2014
6d19922
kafka-1438 (follow-up); Migrate client tools out of perf; patched by…
Jun 9, 2014
b04a3be
KAFKA-1298 (followup); Controlled shutdown tool doesn't seem to work …
Jun 10, 2014
dee1645
KAFKA-1382. Update zkVersion on partition state update failures; revi…
nehanarkhede Jun 10, 2014
bb01847
KAFKA-1472; Add the compression ratio metrics in the new producer; pa…
lindong28 Jun 10, 2014
dcc8840
KAFKA-1488; new metrics for measuring the ratio when the new producer…
junrao Jun 11, 2014
548d1ba
KAFKA-1326 Refactor Sender to support consumer.
jkreps Jun 11, 2014
dd048d8
KAFKA-1382 follow up patch; reviewed by Neha Narkhede
Jun 19, 2014
d0c019a
KAFKA-1316 Follow-up patch for concurrent modification exception.
jkreps Jun 18, 2014
6b0ae4b
KAFKA-1291 Add wrapper scripts and usage information to each command.
jkreps Jun 18, 2014
62f2087
KAFKA-1096 An old controller coming out of long GC could update its e…
Jun 26, 2014
c4b9564
KAFKA-1491; Always read coordinator information in consumer metadata …
jjkoshy Jun 27, 2014
f1c6e97
KAFKA-1498 Misc. producer performance enhancements. Patch from Guozhang.
jkreps Jul 1, 2014
e3dfad3
KAFKA-1498 Follow-up: add metric on avg record size.
jkreps Jul 1, 2014
b8d87d0
KAFKA-1308 Publish jar of test utilities to Maven
jghoman Jul 2, 2014
2a4718c
kafka-1503; all partitions are using same broker as their leader afte…
jackiewang518 Jul 3, 2014
b1a1cae
kafka-1513; Cleanup KafkaServerStartable code; patched by Evgeny Vere…
evverx Jul 3, 2014
6de56b3
KAFKA-1519 Make it possible to disable the line seperator in the cons…
jkreps Jul 4, 2014
cd3ce27
KAFKA-1515 Fix a bug that could result in blocking for a long period …
jkreps Jul 8, 2014
420628d
kafka-1325; Fix inconsistent per topic log configs; patched by Maniku…
omkreddy Jul 10, 2014
8034390
kafka-1406; Fix scaladoc/javadoc warnings; patched by Alan Lee; revie…
coderiff Jul 10, 2014
83a9aa5
KAFKA-1515 Producer can hang during metadata updates. Patch by Guozhang.
jkreps Jul 11, 2014
4b3d03e
KAFKA-1258 Automatically delete temporary directories with a shutdown…
jkreps Jul 12, 2014
3e6b386
kafka-1529; transient unit test failure in testAutoCreateAfterDeleteT…
junrao Jul 15, 2014
b428d8c
kafka-1531; zookeeper.connection.timeout.ms is set to 10000000 in con…
omkreddy Jul 16, 2014
8e444a3
KAFKA-1512 Add per-ip connection limits.
jkreps Jul 1, 2014
4ebcdfd
KAFKA-1535 Have the metadata response contain all alive brokers rathe…
jkreps Jul 17, 2014
fc0e03f
kafka-1462; Add new request and response formats for the new consumer…
junrao Jul 18, 2014
592678e
KAFKA-1180 WhiteList topic filter gets a NullPointerException on comp…
joestein Jul 20, 2014
1e4b084
KAFKA-1539 Fsync offset checkpoint file after writing.
jkreps Jul 21, 2014
014b700
kafka-1462 (followup patch); Add new request and response formats for…
junrao Jul 22, 2014
ff05e9b
kafka-1533; transient unit test failure in ProducerFailureHandlingTes…
Jul 22, 2014
3f1a9c4
kafka-1192; Enable DumpLogSegments tool to deserialize messages; patc…
omkreddy Jul 24, 2014
db41f98
KAFKA-1544 Log cleaner takes a long time to shut down. Patch from Man…
jkreps Jul 24, 2014
d9e5080
KAFKA-1483 Split Brain about Leader Partitions; reviewed by Guozhang,…
Jul 24, 2014
7f2278f
kafka-1549; dead brokers coming in the TopicMetadataResponse; patched…
Jul 27, 2014
fa34841
kafka-1542; normal IOException in the new producer is logged as ERROR…
heavydawson Jul 27, 2014
f489493
kafka-1414; Speedup broker startup after hard reset; patched by Anton…
ataraxer Jul 28, 2014
50f2b24
kafka-1542 (trivail followup patch to fix NullPointerException); norm…
junrao Jul 28, 2014
a01a101
kafka-1451; Broker stuck due to leader election race; patched by Mani…
omkreddy Jul 30, 2014
f8d521a
kafka-1562; kafka-topics.sh alter add partitions resets cleanup.polic…
Aug 4, 2014
1d2e776
kafka-1571; MetadataTest hangs; patched by Jun Rao; reviewed by Guozh…
junrao Aug 5, 2014
0386790
trivial change to remove a compilation warning; patched by Jun Rao
junrao Aug 5, 2014
09690e3
KAFKA-1550; Patch review tool should use git format-patch for patch g…
lindong28 Aug 5, 2014
7a67a72
KAFKA-1485 Upgrade to Zookeeper 3.4.6 patch by Gwen Shapira reviewed …
Aug 5, 2014
0dc243b
kafka-1430; Purgatory redesign; patched by Guozhang Wang; reviewed by…
Aug 6, 2014
c9894fb
kafka-1578; Controller should de-register all listeners upon designat…
Aug 8, 2014
4d07597
kafka-1419; cross build for scala 2.11; patched by Ivan Lyutov; revie…
edgefox Aug 11, 2014
0607953
kafka-1574; unit tests can hang on socketserver shutdown; patched by …
junrao Aug 11, 2014
8a8c490
trunk is the 0.8.2 snapshot
joestein Aug 11, 2014
48cc2dc
Revert KAFKA-1485 Upgrade to Zookeeper 3.4.6 since system tests are f…
joestein Aug 12, 2014
aa70a7d
kafka-1567; Metric memory leaking after closing the clients; patched …
becketqin Aug 13, 2014
a552d4b
kafka-1567; Metric memory leaking after closing the clients; patched …
omkreddy Aug 13, 2014
caf256a
KAFKA-1560 Make arguments to jira-python API more explicit in kafka-p…
Aug 15, 2014
d678449
KAFKA-1582; System Test should wait for producer to finish; reviewed …
lindong28 Aug 15, 2014
c6f08b6
KAFKA-1580; Reject producer requests to internal topics; reviewed by …
Aug 15, 2014
7802255
KAFKA-1576: Make delete topic command a little more user-friendly. Pa…
jkreps Aug 18, 2014
f402b7a
kafka-1598; Fix variable typo in Kafka main class; patched by Jarek J…
Aug 18, 2014
a30491a
kafka-1603; MirrorMaker consumer does not put the message key into Pr…
becketqin Aug 20, 2014
aa775a1
kafka-1609; New producer metadata response handling should only exclu…
lindong28 Aug 23, 2014
2cdc83e
KAFKA-1485 Upgrade to Zookeeper 3.4.6 and create shim for ZKCLI so sy…
joestein Aug 29, 2014
538122f
KAFKA-1577; Swallow errors from connection-quotas in closing sockets …
Aug 29, 2014
953e35b
KAFKA-687; Provide a roundrobin partition assignment strategy that co…
jjkoshy Aug 30, 2014
3abe340
KAFKA-1502 source jar is empty patch by Jun Rao reviewed by Joe Stein
joestein Aug 30, 2014
ae24141
KAFKA-1485 Upgrade to Zookeeper 3.4.6 missing file
joestein Sep 2, 2014
ffb81a5
kafka-1616; Purgatory Size and Num.Delayed.Request metrics are incorr…
Sep 5, 2014
e22f8ed
KAFKA-1510; Do full (unfiltered) offset commits when offsets storage …
Sep 5, 2014
3d3c544
KAFKA-1147 Consumer socket timeout should be greater than fetch max w…
Sep 14, 2014
8d0ab1d
kafka-1619; perf dir can be removed; patched by Jun Rao; reviewed by …
junrao Sep 14, 2014
f9d9b38
kafka-1419 (followup); cross build for scala 2.11; patched by Stevo S…
sslavic Sep 14, 2014
f5ab8e1
kafka-1369; snappy version update 1.1.x; patched by Roger Hoover; rev…
theduderog Sep 14, 2014
cb6a159
KAFKA-1611 Improve system test configuration; reviewed by Neha Narkhe…
gwenshap Sep 15, 2014
3e8854c
KAFKA-847 kafka appender layout does not work for kafka 0.7.1; review…
Sep 15, 2014
d677701
KAFKA-1496 Using batch message in sync producer only sends the first …
Sep 15, 2014
cf0f575
KAFKA-1597 New metrics: ResponseQueueSize and BeingSentResponses; rev…
alexism Sep 16, 2014
a1423ae
trivial change to javadoc for makeLeaders(); patched by Lantao Jin
junrao Sep 17, 2014
c892c08
kafka-1620; Make kafka api protocol implementation public; patched by…
ataraxer Sep 17, 2014
be5edd2
kafka-1123; Broker IPv6 addresses parsed incorrectly; patched by Krzy…
kszafran Sep 18, 2014
8eac7d7
KAFKA-1282 Disconnect idle socket connection in Selector; reviewed by…
Sep 20, 2014
6d70575
kafka-1622; project shouldn't require signing to build; patched by Iv…
edgefox Sep 20, 2014
d2d1ef3
KAFKA-1490 remove gradlew initial setup output from source distributi…
joestein Sep 23, 2014
db0b0b8
KAFKA-1490 remove gradlew initial setup output from source distributi…
joestein Sep 23, 2014
27bc372
trivial change to README to make the gradle wrapper download clearer
junrao Sep 23, 2014
084566b
kafka-1645; some more jars in our src release; patched by Joe Stein; …
joestein Sep 25, 2014
f750dba
KAFKA-404 When using chroot path, create chroot on startup if it does…
johann8384 Sep 25, 2014
9c17747
KAFKA-589 Clean shutdown after startup connection failure; reviewed b…
ewencp Sep 26, 2014
a9c7d77
KAFKA-1618 Exception thrown when running console producer with no por…
Sep 26, 2014
6861d46
kafka-1618 (followup); Exception thrown when running console producer…
Sep 29, 2014
54b6419
KAFKA-1577; Follow-up patch: Fix exception in connection-quotas while…
Sep 30, 2014
795e262
bump up release version to 0.8.3
junrao Sep 30, 2014
e05704c
KAFKA-1662 gradle release issue permgen space patch by Sriharsha Chin…
joestein Oct 4, 2014
9cb59f3
KAFKA-1057 Trim whitespaces from user specified configs; reviewed by …
omkreddy Oct 4, 2014
40948a3
KAFKA-1663 Controller unable to shutdown after a soft failure; review…
Oct 5, 2014
f452c42
kafka-1673; potential java.lang.IllegalStateException in BufferPool.a…
junrao Oct 6, 2014
88595bf
KAFKA-1668 Print an error if you try to alter a topic that doesn't ex…
omkreddy Oct 7, 2014
1a6c920
kafka-1468; (followup) add back inadventently removed commit; patched…
Oct 7, 2014
68b9f77
kafka-1644; Inherit FetchResponse from RequestOrResponse; patched by …
ataraxer Oct 8, 2014
c940470
kafka-1670; Corrupt log files for segment.bytes values close to Int.M…
Oct 9, 2014
a7e4929
kafka-1681; Newly elected KafkaController might not start deletion of…
Oct 9, 2014
a314461
kafka-1558; AdminUtils.deleteTopic does not work; patched by Sriharsh…
Oct 9, 2014
58e5852
KAFKA-1648; Robin consumer balance throws an NPE when there are no to…
MayureshGharat Oct 9, 2014
043190c
kafka-1555; provide strong consistency with reasonable availability; …
gwenshap Oct 10, 2014
09b2b3c
kafka-1699; autoRebalanceScheduler.shutdown() causes deadlock while c…
Oct 10, 2014
1733c0b
kafka-1670 (followup to fix system tests); Corrupt log files for segm…
Oct 12, 2014
7062ed7
KAFKA-1692 Include client ID in new producer IO thread name; reviewed…
ewencp Oct 12, 2014
0d65f04
KAFKA-1471 Add producer unit tests for LZ4 and LZ4HC compression code…
ewencp Oct 12, 2014
be2e8a7
KAFKA-1305. Controller can hang on controlled shutdown with auto lead…
Oct 13, 2014
d5041bc
kafka-1702; Messages silently Lost by producer; patched by Alexis Mid…
alexism Oct 13, 2014
22643bf
KAFKA-979 Add jitter for time based rolling; reviewed by Neha Narkhed…
ewencp Oct 15, 2014
de432a0
KAFKA-1637 SimpleConsumer.fetchOffset returns wrong error code when n…
ewencp Oct 15, 2014
841387b
Revert "KAFKA-1637 SimpleConsumer.fetchOffset returns wrong error cod…
jjkoshy Oct 15, 2014
4271ecb
KAFKA-1637 SimpleConsumer.fetchOffset returns wrong error code when n…
nehanarkhede Oct 16, 2014
37356bf
kafka-1493; Use a well-documented LZ4 compression format and remove r…
LLParse Oct 17, 2014
5f1ad10
kafka-1671; uploaded archives are missing for Scala version 2.11; pat…
edgefox Oct 17, 2014
5152fb7
KAFKA-1108 When controlled shutdown attempt fails, the reason is not …
ewencp Oct 17, 2014
2d322a7
kafka-1717; remove netty dependency through ZK 3.4.x; patched by Jun …
junrao Oct 20, 2014
4b09576
kafka-1698; Validator.ensureValid() only validates default config val…
ewencp Oct 21, 2014
e8923ae
KAFKA-1653 Duplicate broker ids allowed in replica assignment; review…
ewencp Oct 22, 2014
cda1f73
kafka-1727; Fix comment about message format; patched by Muneyuki Nog…
mnogu Oct 23, 2014
35f589b
KAFKA-1641; Reset first dirty offset for compaction to earliest offset
Oct 23, 2014
b770996
kafka-1700; examples directory - README and shell scripts are out of …
granders Oct 23, 2014
e402c7b
kafka-1711; WARN Property topic is not valid when running console pro…
jcrobak Oct 24, 2014
12ce4b1
KAFKA-1725 Configuration file bugs in system tests add noise to outpu…
ewencp Oct 24, 2014
43cb192
KAFKA-1719 Make mirror maker exit when one consumer/producer thread e…
becketqin Oct 24, 2014
20f5b01
KAFKA-1732 DumpLogSegments tool fails when path has a '.'; reviewed b…
ewencp Oct 27, 2014
8983120
KAFKA-1583; Encapsulate replicated log implementation details into
Oct 30, 2014
1ed9cf6
KAFKA-1647; Create replicas on follower transition even if leader is
becketqin Oct 30, 2014
58e3f99
kafka-1733; Producer.send will block indeterminately when broker is u…
Nov 4, 2014
4bb0202
KAFKA-1706; Add a byte bounded blocking queue utility; reviewed by Jo…
becketqin Nov 4, 2014
06e1a65
KAFKA-1747 TestcaseEnv improperly shares state between instances; rev…
ewencp Nov 7, 2014
cbdcd5f
KAFKA-1746 System tests don't handle errors well; reviewed by Neha Na…
ewencp Nov 7, 2014
f20e510
kafka-1738; Partitions for topic not created after restart from force…
junrao Nov 7, 2014
9b3da9f
KAFKA-1739 Remove testComplexCompressDecompress in MessageCompression…
omkreddy Nov 10, 2014
53160bb
KAFKA-1742; ControllerContext removeTopic does not correctly update s…
onurkaraman Nov 12, 2014
2cd9ae7
KAFKA-1762; Update max-inflight-requests doc-string in producer confi…
Nov 12, 2014
d99af88
KAFKA-1764; ZookeeperConsumerConnector should not put multiple shutdo…
becketqin Nov 14, 2014
8c35030
Revert "KAFKA-1764; ZookeeperConsumerConnector should not put multipl…
jjkoshy Nov 14, 2014
ca2cf97
KAFKA-1764; ZookeeperConsumerConnector should not put multiple shutdo…
becketqin Nov 14, 2014
7d89867
kafka-1642; [Java New Producer Kafka Trunk] CPU Usage Spike to 100% w…
ewencp Nov 14, 2014
26ad54c
kafka-1721; Snappy compressor is not thread safe; patched by Ewen Che…
ewencp Nov 14, 2014
6f4b8a1
kafka-17693; javadoc should only include client facing packages; patc…
junrao Nov 18, 2014
1c7d783
kafka-1743; ConsumerConnector.commitOffsets in 0.8.2 is not backward …
omkreddy Nov 19, 2014
457744a
kafka-1481; Stop using dashes AND underscores as separators in MBean …
Nov 20, 2014
f0fd709
KAFKA-1770; clarify descriptive comments of UnknownTopicOrPartitionEx…
becketqin Nov 21, 2014
409c367
KAFKA-1654 Provide a way to override server configuration from comman…
Nov 24, 2014
72601f7
KAFKA-1624; bump up default scala version to 2.11.4 to compile with j…
Nov 24, 2014
9f8b8da
KAFKA-1580; disallow non-admin clients to produce to internal (e.g. o…
Nov 24, 2014
834b641
kafka-1667; topic-level configuration not validated; patched by Dmytr…
koiuo Nov 25, 2014
4408f48
KAFKA-1783; Add missing slash in documentation for consumer's ZK path…
jfim Dec 1, 2014
8a719e0
kafka-1799; ProducerConfig.METRIC_REPORTER_CLASSES_CONFIG doesn't wor…
omkreddy Dec 2, 2014
74bc886
kafka-1799; (add missing test file) ProducerConfig.METRIC_REPORTER_CL…
omkreddy Dec 2, 2014
b24f9c0
kafka-1798; ConfigDef.parseType() should throw exception on invalid b…
delow12 Dec 2, 2014
723fa4c
KAFKA-328 Write unit test for kafka server startup and shutdown API; …
Dec 2, 2014
15f9e27
kafka-1801; Remove non-functional variable definition in log4j.proper…
rocketraman Dec 3, 2014
7e9368b
kafka-1803; UncleanLeaderElectionEnableProp in LogConfig should be of…
bookshelfdave Dec 3, 2014
3cc10d5
KAFKA-1720; Renamed Delayed Operations after KAFKA-1583; reviewed by …
Dec 4, 2014
09e2fd6
KAFKA-1173 Using Vagrant to get up and running with Apache Kafka patc…
joestein Dec 5, 2014
4fc7495
KAFKA-1807 Improve accuracy of ProducerPerformance target throughput;…
ewencp Dec 5, 2014
2801629
KAFKA-1650; avoid data loss when mirror maker shutdown uncleanly; rev…
becketqin Dec 5, 2014
e8ffbd0
KAFKA-1812 Allow IpV6 in configuration with parseCsvMap patch by Jeff…
joestein Dec 12, 2014
0ef631b
kafka-1815; ServerShutdownTest fails in trunk; patched by Chris Cope;…
Dec 12, 2014
523b365
kafka-1813; Build fails for scala 2.9.2; patched by Anatoly Fayngeler…
fanatoly Dec 12, 2014
ae0bb84
KAFKA-742: Existing directories under the Kafka data directory withou…
Dec 17, 2014
92d1d4c
kafka-1797; add the serializer/deserializer api to the new java clien…
junrao Dec 18, 2014
8452187
KAFKA-1824 - fix ConsoleProducer so parse.key and key.separator will …
gwenshap Dec 19, 2014
5847097
add judgement for ConsumerPerformance against negative number
Dec 24, 2014
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
The table of contents is too big for display.
Diff view
Diff view
  •  
  •  
  •  
14 changes: 13 additions & 1 deletion .gitignore
Original file line number Diff line number Diff line change
@@ -1,11 +1,12 @@
dist
*classes
target/
build/
.gradle/
lib_managed/
src_managed/
project/boot/
project/plugins/project/
project/sbt_project_definition.iml
.idea
.svn
.classpath
Expand All @@ -14,3 +15,14 @@ project/sbt_project_definition.iml
.#*
rat.out
TAGS
*.iml
.project
.settings
.gradle
kafka.ipr
kafka.iws
.vagrant
Vagrantfile.local

config/server-*
config/zookeeper-*
31 changes: 0 additions & 31 deletions LICENSE
Original file line number Diff line number Diff line change
Expand Up @@ -200,34 +200,3 @@
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.

-----------------------------------------------------------------------

SBT LICENSE

Copyright (c) 2008, 2009, 2010 Mark Harrah, Jason Zaugg
All rights reserved.

Redistribution and use in source and binary forms, with or without
modification, are permitted provided that the following conditions
are met:
1. Redistributions of source code must retain the above copyright
notice, this list of conditions and the following disclaimer.
2. Redistributions in binary form must reproduce the above copyright
notice, this list of conditions and the following disclaimer in the
documentation and/or other materials provided with the distribution.
3. The name of the author may not be used to endorse or promote products
derived from this software without specific prior written permission.

THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
(INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.

-----------------------------------------------------------------------
60 changes: 0 additions & 60 deletions README-sbt.md

This file was deleted.

141 changes: 83 additions & 58 deletions README.md
Original file line number Diff line number Diff line change
@@ -1,81 +1,106 @@
# Licensed to the Apache Software Foundation (ASF) under one or more
# contributor license agreements. See the NOTICE file distributed with
# this work for additional information regarding copyright ownership.
# The ASF licenses this file to You under the Apache License, Version 2.0
# (the "License"); you may not use this file except in compliance with
# the License. You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.

# Apache Kafka #
Apache Kafka
=================
See our [web site](http://kafka.apache.org) for details on the project.

## Building a jar and running it ##
1. ./gradlew copyDependantLibs
2. ./gradlew jar
3. Follow instuctions in http://kafka.apache.org/documentation.html#quickstart
You need to have [gradle](http://www.gradle.org/installation) installed.

## Running unit tests ##
./gradlew test
### First bootstrap and download the wrapper ###
cd kafka_source_dir
gradle

## Forcing re-running unit tests w/o code change ##
./gradlew cleanTest test
Now everything else will work

## Running a particular unit test ##
./gradlew -Dtest.single=RequestResponseSerializationTest core:test
### Building a jar and running it ###
./gradlew jar

Follow instuctions in http://kafka.apache.org/documentation.html#quickstart

### Building source jar ###
./gradlew srcJar

### Building javadocs and scaladocs ###
./gradlew javadoc
./gradlew javadocJar # builds a jar from the javadocs
./gradlew scaladoc
./gradlew scaladocJar # builds a jar from the scaladocs
./gradlew docsJar # builds both javadoc and scaladoc jar

### Running unit tests ###
./gradlew test

### Forcing re-running unit tests w/o code change ###
./gradlew cleanTest test

### Running a particular unit test ###
./gradlew -Dtest.single=RequestResponseSerializationTest core:test

### Running a particular unit test with log4j output ###
change the log4j setting in either clients/src/test/resources/log4j.properties or core/src/test/resources/log4j.properties
./gradlew -i -Dtest.single=RequestResponseSerializationTest core:test

### Building a binary release gzipped tar ball ###
./gradlew clean
./gradlew releaseTarGz
The above command will fail if you haven't set up the signing key. To bypass signing the artifact, you can run
./gradlew releaseTarGz -x signArchives

## Building a binary release gzipped tar ball ##
./gradlew clean
./gradlew releaseTarGz
The release file can be found inside ./core/build/distributions/.

## Cleaning the build ##
./gradlew clean
### Cleaning the build ###
./gradlew clean

### Running a task on a particular version of Scala (either 2.9.1, 2.9.2, 2.10.1 or 2.11) ###
#### (If building a jar with a version other than 2.10, need to set SCALA_BINARY_VERSION variable or change it in bin/kafka-run-class.sh to run quick start.) ####
./gradlew -PscalaVersion=2.9.1 jar
./gradlew -PscalaVersion=2.9.1 test
./gradlew -PscalaVersion=2.9.1 releaseTarGz

### Running a task for a specific project ###
This is for 'core', 'contrib:hadoop-consumer', 'contrib:hadoop-producer', 'examples' and 'clients'
./gradlew core:jar
./gradlew core:test

### Listing all gradle tasks ###
./gradlew tasks

### Building IDE project ####
./gradlew eclipse
./gradlew idea

## Running a task on a particular version of Scala (either 2.8.0, 2.8.2, 2.9.1, 2.9.2 or 2.10.1) ##
## (If building a jar with a version other than 2.8.0, the scala version variable in bin/kafka-run-class.sh needs to be changed to run quick start.) ##
./gradlew -PscalaVersion=2.9.1 jar
./gradlew -PscalaVersion=2.9.1 test
./gradlew -PscalaVersion=2.9.1 releaseTarGz
### Building the jar for all scala versions and for all projects ###
./gradlew jarAll

## Running a task for a specific project in 'core', 'perf', 'contrib:hadoop-consumer', 'contrib:hadoop-producer', 'examples', 'clients' ##
./gradlew core:jar
./gradlew core:test
### Running unit tests for all scala versions and for all projects ###
./gradlew testAll

## Listing all gradle tasks ##
./gradlew tasks
### Building a binary release gzipped tar ball for all scala versions ###
./gradlew releaseTarGzAll

# Building IDE project ##
./gradlew eclipse
./gradlew idea
### Publishing the jar for all version of Scala and for all projects to maven ###
./gradlew uploadArchivesAll

# Building the jar for all scala versions and for all projects ##
./gradlew jarAll
Please note for this to work you should create/update `~/.gradle/gradle.properties` and assign the following variables

## Running unit tests for all scala versions and for all projects ##
./gradlew testAll
mavenUrl=
mavenUsername=
mavenPassword=
signing.keyId=
signing.password=
signing.secretKeyRingFile=

## Building a binary release gzipped tar ball for all scala versions ##
./gradlew releaseTarGzAll
### Building the test jar ###
./gradlew testJar

## Publishing the jar for all version of Scala and for all projects to maven (To test locally, change mavenUrl in gradle.properties to a local dir.) ##
./gradlew uploadArchivesAll
### Determining how transitive dependencies are added ###
./gradlew core:dependencies --configuration runtime

## Building the test jar ##
./gradlew testJar
### Running in Vagrant ###

## Determining how transitive dependencies are added ##
./gradlew core:dependencies --configuration runtime
See [vagrant/README.md](vagrant/README.md).

## Contribution ##
### Contribution ###

Kafka is a new project, and we are interested in building the community; we would welcome any thoughts or [patches](https://issues.apache.org/jira/browse/KAFKA). You can reach us [on the Apache mailing lists](http://kafka.apache.org/contact.html).
Apache Kafka is interested in building the community; we would welcome any thoughts or [patches](https://issues.apache.org/jira/browse/KAFKA). You can reach us [on the Apache mailing lists](http://kafka.apache.org/contact.html).

To contribute follow the instructions here:
* http://kafka.apache.org/contributing.html
Expand Down
Loading