标签使您能够将历史中的特定点标记为重要点
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
0.8.2-beta
a6170d4f · ·New Feature [KAFKA-1227] - Code dump of new producer [KAFKA-1384] - Log Broker state [KAFKA-1443] - Add delete topic to topic commands and update DeleteTopicCommand [KAFKA-1512] - Limit the maximum number of connections per ip address Task [KAFKA-1399] - Drop Scala 2.8.x support [KAFKA-1559] - Upgrade Gradle wrapper to Gradle 2.0 Test [KAFKA-1079] - Liars in PrimitiveApiTest that promise to test api in compression mode, but don't do this actually [KAFKA-1285] - enable log4j in unit test [KAFKA-1411] - remove unused test cases Wish [KAFKA-1308] - Publish jar of test utilities to Maven [KAFKA-1370] - Gradle startup script for Windows [KAFKA-1371] - Ignore build output dirs [KAFKA-1485] - Upgrade to Zookeeper 3.4.6 and create "shim" for ZKCLI so system tests can run Sub-task [KAFKA-784] - creating topic without partitions, deleting then creating with partition causes errors in 'kafka-list-topic' [KAFKA-1240] - Add ability to existing system tests to use the new producer client [KAFKA-1304] - unregistered mbean exception in new producer [KAFKA-1316] - Refactor Sender [KAFKA-1328] - Add new consumer APIs [KAFKA-1359] - Add topic/broker metrics once new topic/broker is discovered [KAFKA-1462] - Add new request and response formats for the new consumer and coordinator communication [KAFKA-1472] - Add the compression ratio metrics in the new producer [KAFKA-1611] - Improve system test configuration Improvement [KAFKA-404] - When using chroot path, create chroot on startup if it doesn't exist [KAFKA-997] - Provide a strict verification mode when reading configuration properties [KAFKA-1028] - per topic configuration of preference for consistency over availability [KAFKA-1204] - Add KAFKA_LOG_DIR to allow LOG_DIR to be outside of code dir [KAFKA-1264] - Make ConsoleProducer compression codec configurable [KAFKA-1278] - More flexible helper scripts [KAFKA-1287] - enable log4j in command line tools using the new producer [KAFKA-1291] - Make wrapper shell scripts for important tools [KAFKA-1298] - Controlled shutdown tool doesn't seem to work out of the box [KAFKA-1312] - Update gitignore to ignore IDE generated files [KAFKA-1325] - Fix inconsistent per topic log configs [KAFKA-1344] - Kafka-console-producer.sh support snappy compression [KAFKA-1348] - Producer's Broker Discovery Interface [KAFKA-1353] - report capacity used by request thread pool and network thread pool [KAFKA-1361] - enable controlled shutdown by default [KAFKA-1390] - TestUtils.waitUntilLeaderIsElectedOrChanged may wait longer than it needs [KAFKA-1392] - all TestUtiles.waitUntilTrue() should throw an exception if the return value is false [KAFKA-1414] - Speedup broker startup after hard reset [KAFKA-1419] - cross build for scala 2.11 [KAFKA-1425] - provide logStartOffset in addition to LogEndOffset metric [KAFKA-1430] - Purgatory redesign [KAFKA-1446] - Consumer metrics for rebalance [KAFKA-1454] - Update for a Scala 2.11 build [KAFKA-1456] - Add LZ4 and LZ4C as a compression codec [KAFKA-1480] - support log.roll.minutes [KAFKA-1488] - new metrics for measuring the ratio when the new producer is block for space allocation [KAFKA-1493] - Use a well-documented LZ4 compression format and remove redundant LZ4HC option [KAFKA-1513] - Cleanup KafkaServerStartable code [KAFKA-1519] - Console consumer: expose configuration option to enable/disable writing the line separator [KAFKA-1535] - return all live brokers in TopicMetadataResponse [KAFKA-1555] - provide strong consistency with reasonable availability [KAFKA-1576] - Make "deleteTopic" a bit more user friendly [KAFKA-1618] - Exception thrown when running console producer with no port number for the broker [KAFKA-1620] - Make kafka api protocol implementation public [KAFKA-1644] - Inherit FetchResponse from RequestOrResponse Bug [KAFKA-179] - Log files always touched when broker is bounced [KAFKA-294] - "Path length must be > 0" error during startup [KAFKA-472] - update metadata in batches in Producer [KAFKA-703] - A fetch request in Fetch Purgatory can double count the bytes from the same delayed produce request [KAFKA-847] - kafka appender layout does not work for kafka 0.7.1 [KAFKA-899] - LeaderNotAvailableException the first time a new message for a partition is processed. [KAFKA-924] - Specify console consumer properties via a single --property command line parameter [KAFKA-1002] - Delete aliveLeaders field from LeaderAndIsrRequest [KAFKA-1025] - Producer.send should provide recoverability info on failiure [KAFKA-1026] - Dynamically Adjust Batch Size Upon Receiving MessageSizeTooLargeException [KAFKA-1034] - Improve partition reassignment to optimize writes to zookeeper [KAFKA-1041] - Number of file handles increases indefinitely in producer if broker host is unresolvable [KAFKA-1061] - Break-down sendTime to multipleSendTime [KAFKA-1096] - An old controller coming out of long GC could update its epoch to the latest controller's epoch [KAFKA-1108] - when controlled shutdown attempt fails, the reason is not always logged [KAFKA-1123] - Broker IPv6 addresses parsed incorrectly [KAFKA-1146] - toString() on KafkaStream gets stuck indefinitely [KAFKA-1147] - Consumer socket timeout should be greater than fetch max wait [KAFKA-1179] - createMessageStreams() in javaapi.ZookeeperConsumerConnector does not throw [KAFKA-1180] - WhiteList topic filter gets a NullPointerException on complex Regex [KAFKA-1189] - kafka-server-stop.sh doesn't stop broker [KAFKA-1192] - Enable DumpLogSegments tool to deserialize messages [KAFKA-1193] - Data loss if broker is killed using kill -9 [KAFKA-1209] - System test transient failure due to ProducerPerformance's connection to servers kept broken [KAFKA-1210] - Windows Bat files are not working properly [KAFKA-1212] - System test exception handling does not stop background producer threads [KAFKA-1213] - Adding fetcher needs to be avoided upon make-follower when replica manager is shutting down [KAFKA-1238] - New producer hangs in a loop detecting metadata for auto created topics [KAFKA-1276] - Provide a list of config overrides available when running kafka.topics [KAFKA-1280] - exclude kafka-clients jar from dependant-libs dir [KAFKA-1297] - releaseTarGz target needs signing task [KAFKA-1301] - system testcase_0206 fails using the new producer [KAFKA-1302] - cleanup logging in new producer [KAFKA-1305] - Controller can hang on controlled shutdown with auto leader balance enabled [KAFKA-1307] - potential socket leak in new producer and clean up [KAFKA-1318] - waiting for producer to stop is not reliable in system tests [KAFKA-1319] - kafka jar doesn't depend on metrics-annotation any more [KAFKA-1364] - ReplicaManagerTest hard-codes log dir [KAFKA-1369] - snappy version update 1.1.x [KAFKA-1375] - Formatting for "Running a task on a particular version of Scala" paragraph in README.md is broken [KAFKA-1376] - transient test failure in UncleanLeaderElectionTest [KAFKA-1378] - transient unit test failure in LogRecoveryTest [KAFKA-1381] - transient unit test failure in AddPartitionsTest [KAFKA-1382] - Update zkVersion on partition state update failures [KAFKA-1383] - transient unit test failure in SocketServerTest [KAFKA-1389] - transient unit test failure in ProducerFailureHandlingTest [KAFKA-1391] - transient unit test failure in DeleteTopicTest.testPreferredReplicaElectionDuringDeleteTopic [KAFKA-1395] - fix unit tests in AutoOffsetResetTest [KAFKA-1396] - fix transient unit test ProducerFailureHandlingTest.testBrokerFailure [KAFKA-1397] - delete topic is not working [KAFKA-1400] - transient unit test failure in SocketServerTest [KAFKA-1406] - Fix scaladoc/javadoc warnings [KAFKA-1409] - oversized messages can slow down the brokers [KAFKA-1410] - MetadataCache cleanup [KAFKA-1412] - transient unit test failure in ProducerSendTest.testAutoCreateTopic [KAFKA-1418] - transient unit test failure in ProducerFailureHandlingTest [KAFKA-1422] - Fix transient unit test SocketServerTest [KAFKA-1424] - transient unit test failure in testSendWithDeadBroker [KAFKA-1431] - ConsoleConsumer - Option to clean zk consumer path [KAFKA-1432] - Make num.producerThreads configurable on new MirrrorMaker [KAFKA-1433] - transient unit test failure in ZookeeperConsumerConnectorTest [KAFKA-1437] - ConsumerMetadataResponse should always include coordinator information [KAFKA-1438] - Migrate kafka client tools [KAFKA-1439] - transient unit test failure in testDeleteTopicDuringAddPartition [KAFKA-1442] - RBTools post-review is deprecated [KAFKA-1444] - kafka.javaapi.TopicMetadata and PartitionMetadata doesn't forward the toString method [KAFKA-1451] - Broker stuck due to leader election race [KAFKA-1453] - Add a channel queue jmx in Mirror Maker [KAFKA-1459] - kafka.tools.ConsumerOffsetChecker throws NoNodeException [KAFKA-1468] - Improve perf tests [KAFKA-1469] - Util.abs function does not return correct absolute values for negative values [KAFKA-1473] - transient unit test failure in testRequestHandlingDuringDeleteTopic [KAFKA-1482] - Transient test failures for kafka.admin.DeleteTopicTest [KAFKA-1487] - add test jars to gradle build for packaging and release [KAFKA-1490] - remove gradlew initial setup output from source distribution [KAFKA-1491] - ConsumerMetadataResponse is not read completely [KAFKA-1502] - source jar is empty [KAFKA-1503] - all partitions are using same broker as their leader after broker is down [KAFKA-1510] - Force offset commits when migrating consumer offsets from zookeeper to kafka [KAFKA-1511] - Malformated link and consumer/producer mixup in documentation [KAFKA-1529] - transient unit test failure in testAutoCreateAfterDeleteTopic [KAFKA-1531] - zookeeper.connection.timeout.ms is set to 10000000 in configuration file in Kafka tarball [KAFKA-1533] - transient unit test failure in ProducerFailureHandlingTest [KAFKA-1539] - Due to OS caching Kafka might loose offset files which causes full reset of data [KAFKA-1542] - normal IOException in the new producer is logged as ERROR [KAFKA-1544] - LogCleaner may take a long time to shutdown [KAFKA-1549] - dead brokers coming in the TopicMetadataResponse [KAFKA-1557] - ISR reported by TopicMetadataResponse most of the time doesn't match the Zookeeper information (and the truth) [KAFKA-1558] - AdminUtils.deleteTopic does not work [KAFKA-1562] - kafka-topics.sh alter add partitions resets cleanup.policy [KAFKA-1567] - Metric memory leaking after closing the clients [KAFKA-1571] - MetadataeTest hangs [KAFKA-1574] - unit tests can hang on socketserver shutdown [KAFKA-1577] - Exception in ConnectionQuotas while shutting down [KAFKA-1578] - Controller should de-register all listeners upon designation [KAFKA-1585] - Client: Infinite "conflict in /consumers/" [KAFKA-1598] - Fix variable typo in Kafka main class [KAFKA-1600] - Controller failover not working correctly. [KAFKA-1603] - MirrorMaker consumer does not put the message key into ProducerRecord [KAFKA-1609] - New producer metadata response handling should only exclude a PartitionInfo when its error is LEADER_NOT_AVAILABLE [KAFKA-1616] - Purgatory Size and Num.Delayed.Request metrics are incorrect [KAFKA-1619] - perf dir can be removed [KAFKA-1622] - project shouldn't require signing to build [KAFKA-1635] - Java doc of makeLeaders in ReplicaManager is wrong [KAFKA-1645] - some more jars in our src release [KAFKA-1662] - gradle release issue permgen space [KAFKA-1663] - Controller unable to shutdown after a soft failure [KAFKA-1670] - Corrupt log files for segment.bytes values close to Int.MaxInt [KAFKA-1671] - uploaded archives are missing for Scala version 2.11 [KAFKA-1673] - potential java.lang.IllegalStateException in BufferPool.allocate() [KAFKA-1681] - Newly elected KafkaController might not start deletion of pending topics [KAFKA-1699] - autoRebalanceScheduler.shutdown() causes deadlock while controller shutting down [KAFKA-1717] - remove netty dependency through ZK 3.4.x
-
0.8.1.1
150d0a70 · ·Bug [KAFKA-1310] - Zookeeper timeout causes deadlock in Controller [KAFKA-1311] - Add a flag to turn off delete topic until it is stable [KAFKA-1315] - log.dirs property in KafkaServer intolerant of trailing slash [KAFKA-1317] - KafkaServer 0.8.1 not responding to .shutdown() cleanly, possibly related to TopicDeletionManager or MetricsMeter state [KAFKA-1323] - log.dirs server property no longer supports relative directories [KAFKA-1350] - Fix excessive state change logging [KAFKA-1355] - Reduce/optimize update metadata requests sent during leader election [KAFKA-1358] - Broker throws exception when reconnecting to zookeeper [KAFKA-1362] - Publish sources and javadoc jars [KAFKA-1363] - testTopicConfigChangesDuringDeleteTopic hangs [KAFKA-1365] - Second Manual preferred replica leader election command always fails [KAFKA-1373] - LogCleaner assumes first dirty offset zero if there is no cleaner checkpoint [KAFKA-1398] - Topic config changes can be lost and cause fatal exceptions on broker restarts Task [KAFKA-1413] - bump kafka version to 0.8.1.1 in gradle.properties
-
-
0.8.1
b5971264 · ·Release Notes - Kafka - Version 0.8.1 ** New Feature * [KAFKA-554] - Move all per-topic configuration into ZK and add to the CreateTopicCommand * [KAFKA-561] - Rebuild index file for a log segment if there is none * [KAFKA-657] - Add an API to commit offsets * [KAFKA-918] - Change log.retention.hours to be log.retention.mins * [KAFKA-925] - Add optional partition key override in producer * [KAFKA-1092] - Add server config parameter to separate bind address and ZK hostname * [KAFKA-1117] - tool for checking the consistency among replicas ** Improvement * [KAFKA-347] - change number of partitions of a topic online * [KAFKA-741] - Improve log cleaning dedupe buffer efficiency * [KAFKA-1001] - Handle follower transition in batch * [KAFKA-1084] - Validate properties for custom serializers * [KAFKA-1127] - kafka and zookeeper server should start in daemon mode and log to correct position * [KAFKA-1131] - copy some more files into the release tar and zip that are needed/desired * [KAFKA-1136] - Add subAppend in Log4jAppender for generic usage * [KAFKA-1158] - remove bin/run-rat.sh * [KAFKA-1159] - try to get the bin tar smaller * [KAFKA-1160] - have the pom reference the exclusions necessary so folks don't have to * [KAFKA-1161] - review report of the dependencies, conflicts, and licenses into ivy-report * [KAFKA-1162] - handle duplicate entry for ZK in the pom file * [KAFKA-1163] - see whats going on with the 2.8.0 pom * [KAFKA-1186] - Add topic regex to the kafka-topics tool * [KAFKA-1232] - make TopicCommand more consistent ** Bug * [KAFKA-172] - The existing perf tools are buggy * [KAFKA-184] - Log retention size and file size should be a long * [KAFKA-330] - Add delete topic support * [KAFKA-515] - Log cleanup can close a file channel opnened by Log.read before the transfer completes * [KAFKA-615] - Avoid fsync on log segment roll * [KAFKA-648] - Use uniform convention for naming properties keys * [KAFKA-671] - DelayedProduce requests should not hold full producer request data * [KAFKA-677] - Retention process gives exception if an empty segment is chosen for collection * [KAFKA-712] - Controlled shutdown tool should provide a meaningful message if a controller failover occurs during the operation * [KAFKA-739] - Handle null values in Message payload * [KAFKA-759] - Commit/FetchOffset APIs should not return versionId * [KAFKA-852] - Remove clientId from OffsetFetchResponse and OffsetCommitResponse * [KAFKA-897] - NullPointerException in ConsoleConsumer * [KAFKA-930] - Integrate preferred replica election logic into kafka * [KAFKA-933] - Hadoop example running DataGenerator causes kafka.message.Message cannot be cast to [B exception * [KAFKA-985] - Increasing log retention quickly overflows scala Int * [KAFKA-1004] - Handle topic event for trivial whitelist topic filters * [KAFKA-1009] - DumpLogSegments tool should return error on non-existing files * [KAFKA-1020] - Remove getAllReplicasOnBroker from KafkaController * [KAFKA-1036] - Unable to rename replication offset checkpoint in windows * [KAFKA-1052] - integrate add-partitions command into topicCommand * [KAFKA-1055] - BrokerTopicStats is updated before checking for MessageSizeTooLarge * [KAFKA-1060] - Break-down sendTime into responseQueueTime and the real sendTime * [KAFKA-1074] - Reassign partitions should delete the old replicas from disk * [KAFKA-1090] - testPipelinedRequestOrdering has transient failures * [KAFKA-1091] - full topic list can be read from metadata cache in the broker instead of ZK * [KAFKA-1097] - Race condition while reassigning low throughput partition leads to incorrect ISR information in zookeeper * [KAFKA-1103] - Consumer uses two zkclients * [KAFKA-1104] - Consumer uses two zkclients * [KAFKA-1112] - broker can not start itself after kafka is killed with -9 * [KAFKA-1116] - Need to upgrade sbt-assembly to compile on scala 2.10.2 * [KAFKA-1121] - DumpLogSegments tool should print absolute file name to report inconsistencies * [KAFKA-1128] - Github is still showing 0.7 as the default branch * [KAFKA-1129] - if we have a script to run the jar then we should include it in the build or remove it during release * [KAFKA-1133] - LICENSE and NOTICE files need to get into META-INF when jars are built before they're signed for publishing to maven * [KAFKA-1135] - Code cleanup - use Json.encode() to write json data to zk * [KAFKA-1140] - Move the decoding logic from ConsumerIterator.makeNext to next * [KAFKA-1141] - make changes to downloads for the archive old releases to new old_releases folder * [KAFKA-1151] - The Hadoop consumer API doc is not referencing the contrib consumer * [KAFKA-1152] - ReplicaManager's handling of the leaderAndIsrRequest should gracefully handle leader == -1 * [KAFKA-1154] - replicas may not have consistent data after becoming follower * [KAFKA-1156] - Improve reassignment tool to output the existing assignment to facilitate rollbacks * [KAFKA-1157] - Clean up Per-topic Configuration from Kafka properties * [KAFKA-1164] - kafka should depend on snappy 1.0.5 (instead of 1.0.4.1) * [KAFKA-1166] - typo in kafka-server-stop.sh * [KAFKA-1168] - OfflinePartitionCount in JMX can be incorrect during controlled shutdown * [KAFKA-1169] - missing synchronization in access to leaderCache in KafkaApis * [KAFKA-1170] - ISR can be inconsistent during partition reassignment for low throughput partitions * [KAFKA-1172] - error when creating topic with kafka-topics.sh * [KAFKA-1183] - DefaultEventHandler causes unbalanced distribution of messages across partitions * [KAFKA-1198] - NullPointerException in describe topic * [KAFKA-1200] - inconsistent log levels when consumed offset is reset * [KAFKA-1202] - optimize ZK access in KafkaController * [KAFKA-1205] - README in examples not update * [KAFKA-1208] - Update system test still to use kafka-topics instead of kafka-create-topics shell * [KAFKA-1214] - Support arguments to zookeeper-shell.sh script * [KAFKA-1228] - Socket Leak on ReplicaFetcherThread * [KAFKA-1243] - Gradle issues for release * [KAFKA-1263] - Snazzy up the README markdown for better visibility on github * [KAFKA-1271] - controller logs exceptions during ZK session expiration * [KAFKA-1275] - fixes for quickstart documentation ** Task * [KAFKA-823] - merge 0.8 (51421fcc0111031bb77f779a6f6c00520d526a34) to trunk * [KAFKA-896] - merge 0.8 (988d4d8e65a14390abd748318a64e281e4a37c19) to trunk * [KAFKA-965] - merge c39d37e9dd97bf2462ffbd1a96c0b2cb05034bae from 0.8 to trunk * [KAFKA-1051] - merge from 0.8 da4512174b6f7c395ffe053a86d2c6bb19d2538a to trunk * [KAFKA-1080] - why are builds for 2.10 not coming out with the trailing minor version number ** Sub-task * [KAFKA-121] - pom should include standard maven niceties * [KAFKA-1244] - The LICENSE and NOTICE are missing from the jar files * [KAFKA-1245] - the jar files and pom are not being signed so nexus is failing to publish them * [KAFKA-1246] - The 2.10 version is showing up as 2.10.1 * [KAFKA-1248] - jars are missing from maven upload that were previously there * [KAFKA-1249] - release tar name is different than 0.8.0 * [KAFKA-1254] - remove vestigial sbt * [KAFKA-1274] - gradle.properties needs the variables used in the build.gradle