發(fā)行說(shuō)明 - Kafka - 版本1.0.0

以下是Kafka 1.0.0發(fā)行版中解決的JIRA問(wèn)題的摘要省核。有關(guān)該版本的完整文檔，入門(mén)指南以及有關(guān)該項(xiàng)目的信息，請(qǐng)參閱Kafka項(xiàng)目網(wǎng)站冀墨。

有關(guān)升級(jí)的注意事項(xiàng)：在升級(jí)群集之前鳞溉，請(qǐng)仔細(xì)閱讀此版本的 升級(jí)文檔脊凰。升級(jí)說(shuō)明討論關(guān)于不兼容的重要信息以及突破性變化掏愁，性能變化以及可能影響您的Kafka生產(chǎn)部署的任何其他變更匿醒。

最新版本的文檔可以在http://kafka.apache.org/documentation.html找到 。

新功能

[ KAFKA-4602 ] - KIP-72允許對(duì)傳入請(qǐng)求消耗的內(nèi)存進(jìn)行綁定
[ KAFKA-4819 ] - 公開(kāi)API的活動(dòng)任務(wù)的狀態(tài)
[ KAFKA-5341 ] - 添加UnderMinIsrPartitionCount和每個(gè)分區(qū)UnderMinIsr指標(biāo)
[ KAFKA-5651 ] - KIP-182：減少數(shù)據(jù)流DSL過(guò)載萍肆，并允許更容易地使用自定義存儲(chǔ)引擎
[ KAFKA-5694 ] - 添加ChangeReplicaDirRequest和DescribeReplicaDirRequest（KIP-113）
[ KAFKA-5738 ] - 為所有Kafka費(fèi)率度量添加累積計(jì)數(shù)屬性
[ KAFKA-5746 ] - 增加新的指標(biāo)來(lái)支持健康檢查
[ KAFKA-5854 ] - 將SASL身份驗(yàn)證失敗作為客戶端中的不可回溯異常處理
起色

[ KAFKA-1595 ] - 刪除不推薦的和較慢的Scala JSON解析器
[ KAFKA-2376 ] - 添加Kafka Connect指標(biāo)
[ KAFKA-3741 ] - 允許通過(guò)StreamsConfig設(shè)置默認(rèn)主題配置
[ KAFKA-4108 ] - 改進(jìn)DumpLogSegments偏移量 - 解碼器輸出格式
[ KAFKA-4260 ] - 改進(jìn)配置監(jiān)聽(tīng)器的文檔= PLAINTEXT：//0.0.0.0：9092
[ KAFKA-4322 ] - StateRestoreCallback開(kāi)始和結(jié)束指示
[ KAFKA-4380 ] - 更新干凈關(guān)機(jī)文件的使用說(shuō)明袍榆。
[ KAFKA-4416 ] - 為控制臺(tái)客戶添加一個(gè)“--group”選項(xiàng)
[ KAFKA-4501 ] - 支持Java 9
[ KAFKA-4504 ] - 在Topic級(jí)別的retention.bytes屬性的詳細(xì)信息不清楚它們?nèi)绾斡绊懛謪^(qū)大小
[ KAFKA-4763 ] - 處理JBOD（KIP-112）的磁盤(pán)故障
[ KAFKA-4764 ] - 改進(jìn)SASL認(rèn)證失敗的診斷
[ KAFKA-5076 ] - 刪除JDK9中默認(rèn)隱藏的java.xml.bind。*類(lèi)的用法
[ KAFKA-5077 ] - 使服務(wù)器啟動(dòng)腳本針對(duì)Java 9
[ KAFKA-5096 ] - 只記錄無(wú)效的用戶配置并用正確的配置覆蓋
[ KAFKA-5233 ] - 標(biāo)點(diǎn)語(yǔ)義（KIP-138）
[ KAFKA-5330 ] - 使用Connect中的每個(gè)任務(wù)轉(zhuǎn)換器
[ KAFKA-5358 ] - 消費(fèi)者工具應(yīng)分別計(jì)算再平衡時(shí)間
[ KAFKA-5363 ] - 增加批量恢復(fù)和恢復(fù)統(tǒng)計(jì)數(shù)據(jù)的能力塘揣。
[ KAFKA-5384 ] - KIP-162：默認(rèn)啟用刪除主題
[ KAFKA-5410 ] - 修復(fù)Connector中的taskClass（）方法名和SinkTask中的flush（）簽名
[ KAFKA-5439 ] - 在集成測(cè)試中添加檢查以驗(yàn)證線程是否已關(guān)閉
[ KAFKA-5454 ] - 添加一個(gè)新的Kafka Streams示例物聯(lián)網(wǎng)導(dǎo)向
[ KAFKA-5461 ] - KIP-168：為每個(gè)群集添加GlobalTopicCount指標(biāo)
[ KAFKA-5468 ] - 將源偏移量提交消息更改為信息以匹配接收器行為
[ KAFKA-5470 ] - 在kafka-run-class中將-XX：+ DisableExplicitGC替換為-XX：+ ExplicitGCInvokesConcurrent
[ KAFKA-5485 ] - 流不應(yīng)該暫停任務(wù)兩次
[ KAFKA-5495 ] - 在文檔中替換棄用的“ConsumerOffsetChecker”
[ KAFKA-5515 ] - 考慮從Segments類(lèi)中刪除日期格式
[ KAFKA-5516 ] - 以類(lèi)似的方式格式化可驗(yàn)證的生產(chǎn)者/消費(fèi)者產(chǎn)出
[ KAFKA-5525 ] - 流量復(fù)位工具應(yīng)該有相同的控制臺(tái)輸出包雀，有或沒(méi)有干運(yùn)行
[ KAFKA-5542 ] - 改進(jìn)LeaderEpochFileCache.endOffsetFor（）的Java文檔
[ KAFKA-5547 ] - 如果沒(méi)有主題描述訪問(wèn)，則返回主題授權(quán)失敗
[ KAFKA-5549 ] - 解釋client.id只是用作Streams中的前綴
[ KAFKA-5557 ] - 在StreamPartitionAssignor中使用logPrefix
[ KAFKA-5602 ] - 為ducker-ak添加 - 定制ducktape標(biāo)志
[ KAFKA-5629 ] - 控制臺(tái)用戶在命令行提供時(shí)會(huì)覆蓋auto.offset.reset屬性勿负，而不會(huì)發(fā)出警告馏艾。
[ KAFKA-5657 ] - 在描述連接器時(shí)劳曹，連接REST API應(yīng)該包括連接器類(lèi)型
[ KAFKA-5695 ] - 在AuthorizerIntegrationTest中測(cè)試DeleteRecordsRequest
[ KAFKA-5726 ] - 僅使用Pattern的KafkaConsumer.subscribe（）重載沒(méi)有ConsumerRebalanceListener
[ KAFKA-5743 ] - 所有ducktape服務(wù)應(yīng)將其文件存儲(chǔ)在/ mnt的子目錄中
[ KAFKA-5744 ] - ShellTest：為試圖運(yùn)行不存在的程序添加測(cè)試奴愉，錯(cuò)誤返回
[ KAFKA-5750 ] - 在SimpleAclAuthorizer類(lèi)中將拒絕的日志消息提升為INFO
[ KAFKA-5754 ] - 重構(gòu)流使用LogContext
[ KAFKA-5755 ] - 重構(gòu)生產(chǎn)者使用LogContext
[ KAFKA-5762 ] - 重構(gòu)AdminClient以使用LogContext
[ KAFKA-5763 ] - 重構(gòu)NetworkClient以使用LogContext
[ KAFKA-5768 ] - 將ducktape版本升級(jí)到0.7.1，并使用新的kill_java_processes
[ KAFKA-5783 ] - 實(shí)現(xiàn)KafkaPrincipalBuilder接口铁孵，支持SASL（KIP-189）
[ KAFKA-5820 ] - 刪除StreamThread中不需要的同步關(guān)鍵字
[ KAFKA-5822 ] - 統(tǒng)一記錄主題分區(qū)
[ KAFKA-5856 ] - 添加AdminClient.createPartitions（）
[ KAFKA-5915 ] - 支持在Java 9中映射/直接緩沖區(qū)的映射
[ KAFKA-5920 ] - 將SSL身份驗(yàn)證失敗作為客戶端中的不可修復(fù)異常處理
[ KAFKA-5932 ] - 避免在FlushListeners中調(diào)用fetchPrevious
[ KAFKA-5947 ] - 處理交易生產(chǎn)者和KafkaAdminClient的認(rèn)證失敗
[ KAFKA-5958 ] - 用戶StoreListener不適用于全球商店
[ KAFKA-5985 ] - 提到需要關(guān)閉商店迭代器
[ KAFKA-6004 ] - 啟用自定義身份驗(yàn)證插件將錯(cuò)誤消息返回給客戶端
[ KAFKA-6025 ] - Kafka Streams文件有問(wèn)題
竊聽(tīng)器

[ KAFKA-2105 ] - MetadataRequest中的客戶端上的NullPointerException
[ KAFKA-2360 ] - kafka-consumer-perf-test.sh腳本幫助信息打印無(wú)用的參數(shù)锭硼。
[ KAFKA-3356 ] - 刪除ConsumerOffsetChecker，在0.9中棄用0.11
[ KAFKA-3623 ] - 使KStreamTestDriver從ExternalResource擴(kuò)展
[ KAFKA-3856 ] - 清理Kafka Streams構(gòu)建器API
[ KAFKA-3986 ] - completedReceives可以包含封閉的頻道
[ KAFKA-4585 ] - KIP-163：偏移提取和提交請(qǐng)求使用相同的權(quán)限
[ KAFKA-4669 ] - 當(dāng)NetworkClient.handleCompletedReceives拋出異常時(shí)蜕劝，KafkaProducer.flush掛起
[ KAFKA-4785 ] - 來(lái)自?xún)?nèi)部重新分區(qū)主題的記錄應(yīng)始終使用RecordMetadataTimestampExtractor
[ KAFKA-4830 ] - 增加KStream.print（）以允許用戶在打印的字符串中傳遞額外的參數(shù)
[ KAFKA-4856 ] - 從多個(gè)線程調(diào)用KafkaProducer.close（）可能會(huì)導(dǎo)致虛假錯(cuò)誤
[ KAFKA-4860 ] - Kafka批處理文件不支持帶空格的路徑
[ KAFKA-4913 ] - 創(chuàng)建一個(gè)窗口存儲(chǔ)與一個(gè)段引發(fā)除零錯(cuò)誤
[ KAFKA-5127 ] - 在案件“無(wú)”未被使用的情況下檀头，將模式匹配替換為foreach
[ KAFKA-5140 ] - 片狀ResetIntegrationTest
[ KAFKA-5152 ] - Kafka Streams在啟動(dòng)過(guò)程中啟動(dòng)關(guān)機(jī)后保持恢復(fù)狀態(tài)
[ KAFKA-5167 ] - 由于LockException而重新平衡之后轰异，流任務(wù)會(huì)卡住
[ KAFKA-5225 ] - StreamsResetter不允許自定義使用者屬性
[ KAFKA-5239 ] - 生產(chǎn)者緩沖池在鎖內(nèi)分配內(nèi)存。
[ KAFKA-5379 ] - ProcessorContext.appConfigs（）應(yīng)返回解析/驗(yàn)證值
[ KAFKA-5402 ] - 當(dāng)客戶端配額未啟用時(shí)暑始，不應(yīng)創(chuàng)建JmxReporter獲取kafka.server的指標(biāo)
[ KAFKA-5412 ] - 使用connect-console-sink / source.properties引發(fā)與“file”屬性相關(guān)的異常
[ KAFKA-5417 ] - 當(dāng)SASL / SSL連接同時(shí)標(biāo)記為CONECTED和DISCONNECTED時(shí)搭独，客戶端將獲得不一致的連接狀態(tài)
[ KAFKA-5431 ] - LogCleaner由于org.apache.kafka.common.errors.CorruptRecordException而停止
[ KAFKA-5464 ] - StreamsKafkaClient不應(yīng)該使用StreamsConfig.POLL_MS_CONFIG
[ KAFKA-5469 ] - 創(chuàng)建的狀態(tài)更改日志主題未正確記錄
[ KAFKA-5481 ] - 在啟用跟蹤級(jí)別的情況下，ListOffsetResponse未以正確的方式記錄
[ KAFKA-5484 ] - 重構(gòu)kafkatest碼頭支持
[ KAFKA-5487 ] - 滾動(dòng)升級(jí)測(cè)試
[ KAFKA-5506 ] - bin / kafka-consumer-groups.sh無(wú)法查詢(xún)偏移量
[ KAFKA-5507 ] - kafka-run-class.sh不檢查空的$ CLASSPATH
[ KAFKA-5508 ] - 修改主題的文檔
[ KAFKA-5512 ] - KafkaConsumer：閑置時(shí)的內(nèi)存分配率較高
[ KAFKA-5534 ] - 即使沒(méi)有找到偏移量廊镜，KafkaConsumer offsetsForTimes也應(yīng)該包含結(jié)果分區(qū)
[ KAFKA-5535 ] - 轉(zhuǎn)換 - 在墓碑事件上轉(zhuǎn)化價(jià)值
[ KAFKA-5544 ] - 刪除分區(qū)時(shí)牙肝，應(yīng)刪除LastStableOffsetLag指標(biāo)
[ KAFKA-5548 ] - SchemaBuilder不驗(yàn)證輸入。
[ KAFKA-5556 ] - KafkaConsumer.commitSync拋出IllegalStateException：嘗試從未失敗的未檢索異常
[ KAFKA-5566 ] - 不穩(wěn)定的測(cè)試QueryableStateIntegrationTest.shouldAllowToQueryAfterThreadDied
[ KAFKA-5567 ] - 通過(guò)改變主題分區(qū)提交偏移的轉(zhuǎn)換應(yīng)該引用原始主題分區(qū)
[ KAFKA-5576 ] - 通過(guò)更新rocksdb版本支持Power平臺(tái)
[ KAFKA-5579 ] - SchemaBuilder.type（Schema.Type）不應(yīng)該允許null嗤朴。
[ KAFKA-5587 ] - 處理器未捕獲的異常：NullPointerException
[ KAFKA-5595 ] - SocketServer中的非法狀態(tài); 嘗試使用另一個(gè)發(fā)送進(jìn)行發(fā)送
[ KAFKA-5599 ] - ConsoleConsumer： - 不推薦使用新用戶選項(xiàng)
[ KAFKA-5600 ] - 組加載回歸導(dǎo)致過(guò)時(shí)的元數(shù)據(jù)/偏移量緩存
[ KAFKA-5603 ] - 流關(guān)閉僵尸任務(wù)時(shí)不應(yīng)該中止交易
[ KAFKA-5607 ] - 改善SocketServer中的錯(cuò)誤處理以減少非法狀態(tài)
[ KAFKA-5608 ] - 超時(shí)啟動(dòng)Jmx工具導(dǎo)致系統(tǒng)測(cè)試失敗
[ KAFKA-5610 ] - KafkaApis.handleWriteTxnMarkerRequest可以在分區(qū)移出時(shí)返回UNSUPPORTED_FOR_MESSAGE_FORMAT錯(cuò)誤
[ KAFKA-5619 ] - 在所有工具中建議使用新消費(fèi)者選項(xiàng)
[ KAFKA-5620 ] - doSend（）中的SerializationException掩碼類(lèi)轉(zhuǎn)換異常
[ KAFKA-5623 ] - ducktape kafka服務(wù)：不要假設(shè)服務(wù)包含num_nodes
[ KAFKA-5630 ] - 在CorruptRecordException之后配椭，消費(fèi)者循環(huán)遍歷相同的記錄
[ KAFKA-5643 ] - 使用_DUCKTAPE_OPTIONS對(duì)執(zhí)行測(cè)試沒(méi)有影響
[ KAFKA-5644 ] - 瞬態(tài)測(cè)試失敗：ResetConsumerGroupOffsetTest.testResetOffsetsToZonedDateTime
[ KAFKA-5656 ] - 支持KafkaMbean中不存在某些屬性的批量屬性請(qǐng)求
[ KAFKA-5663 ] - LogDirFailureTest系統(tǒng)測(cè)試失敗
[ KAFKA-5668 ] - 可查詢(xún)狀態(tài)窗口存儲(chǔ)范圍掃描僅返回一個(gè)存儲(chǔ)的結(jié)果
[ KAFKA-5679 ] - 添加日志記錄以區(qū)分內(nèi)部和外部啟動(dòng)的Kafka關(guān)閉
[ KAFKA-5698 ] - 根據(jù)TopologyDescription.toString（）中的名稱(chēng)后綴對(duì)處理器節(jié)點(diǎn)進(jìn)行排序
[ KAFKA-5701 ] - 單元測(cè)試shouldTogglePrepareForBulkLoadDuringRestoreCalls失敗
[ KAFKA-5704 ] - 自動(dòng)創(chuàng)建主題會(huì)導(dǎo)致舊集群失敗
[ KAFKA-5711 ] - 批量恢復(fù)應(yīng)該處理刪除
[ KAFKA-5717 ] - [流]在國(guó)家商店的'空'值
[ KAFKA-5720 ] - 在Jenkins中雹姊，kafka.api.SaslSslAdminClientIntegrationTest失敗股缸，出現(xiàn)org.apache.kafka.common.errors.TimeoutException
[ KAFKA-5730 ] - 消費(fèi)者應(yīng)確保同步和異步偏移提交之間的一致順序
[ KAFKA-5733 ] - 系統(tǒng)測(cè)試得到異常RocksDBException：db比options.num_levels更多的級(jí)別
[ KAFKA-5735 ] - 客戶端和代理不一致地處理客戶端ID
[ KAFKA-5737 ] - KafkaAdminClient線程應(yīng)該是守護(hù)進(jìn)程
[ KAFKA-5745 ] - 在成為領(lǐng)導(dǎo)者之前，Partition.makeLeader（）應(yīng)該將HW轉(zhuǎn)換為OffsetMetadata
[ KAFKA-5752 ] - 刪除主題吱雏，重新創(chuàng)建主題立即刪除新主題的時(shí)間索引
[ KAFKA-5753 ] - 在MacOS上ShellTest.testRunProgramWithErrorReturn失敗
[ KAFKA-5756 ] - 刷新同步問(wèn)題
[ KAFKA-5758 ] - 重新分配主題的分區(qū)可能會(huì)對(duì)其他主題產(chǎn)生不利影響
[ KAFKA-5765 ] - 將合并（）從StreamsBuilder移動(dòng)到KStream
[ KAFKA-5767 ] - 如果IBP <1.0.0敦姻，卡夫卡服務(wù)器應(yīng)該停止，并且有日志目錄失敗
[ KAFKA-5771 ] - org.apache.kafka.streams.state.internals.Segments＃段方法返回不正確的結(jié)果時(shí)段添加亂序
[ KAFKA-5774 ] - WorkerSinkTask失敗異常應(yīng)該包括原因
[ KAFKA-5787 ] - StoreChangeLogReader需要恢復(fù)在初始化后添加的分區(qū)
[ KAFKA-5790 ] - 如果引發(fā)異常歧杏，SocketServer.processNewResponses不應(yīng)該跳過(guò)響應(yīng)
[ KAFKA-5797 ] - StoreChangelogReader應(yīng)該對(duì)代理端元數(shù)據(jù)不可用
[ KAFKA-5804 ] - 在寫(xiě)入日志時(shí)替劈，ChangeLoggingWindowBytesStore需要保留重復(fù)項(xiàng)
[ KAFKA-5818 ] - KafkaStreams狀態(tài)轉(zhuǎn)換不正確
[ KAFKA-5829 ] - 通過(guò)減少不必要的快照文件刪除，在不干凈關(guān)閉后啟動(dòng)加速代理
[ KAFKA-5833 ] - 在InterruptedException中重置線程中斷狀態(tài)
[ KAFKA-5837 ] - 如果使用默認(rèn)的油門(mén)/超時(shí)得滤，則重新分配分區(qū)命令失敗
[ KAFKA-5843 ] - 只有在kafka_mx4jenable設(shè)置為true時(shí)才應(yīng)執(zhí)行Mx4jLoader.maybeLoad
[ KAFKA-5862 ] - 從Streams重置工具中刪除ZK依賴(lài)關(guān)系
[ KAFKA-5864 ] - ReplicaFetcherThread不應(yīng)該因脫機(jī)日志目錄中的副本而死亡
[ KAFKA-5865 ] - 啟用冪等級(jí)的批處理可能會(huì)導(dǎo)致數(shù)據(jù)丟失陨献。
[ KAFKA-5867 ] - Kafka Connect應(yīng)用程序在啟動(dòng)時(shí)應(yīng)記錄信息消息
[ KAFKA-5872 ] - SslSelectorTest.testMuteOnOOM中的暫時(shí)故障
[ KAFKA-5879 ] - 控制器在處理IsrChangeNotification事件時(shí)應(yīng)讀取最新的IsrChangeNotification znodes
[ KAFKA-5908 ] - CompositeReadOnlyWindowStore范圍提取不會(huì)在以不同的開(kāi)始和結(jié)束時(shí)間提取時(shí)返回所有值
[ KAFKA-5918 ] - 修正Kafka Streams中的小錯(cuò)別字和錯(cuò)誤
[ KAFKA-5953 ] - JDBC驅(qū)動(dòng)程序可能會(huì)斷開(kāi)連接類(lèi)加載器隔離
[ KAFKA-5954 ] - 連接系統(tǒng)測(cè)試失敗：ConnectRestApiTest
[ KAFKA-5956 ] - StreamBuilder＃表和StreamsBuilder＃globalTable應(yīng)該使用物化的serdes
[ KAFKA-5957 ] - 生產(chǎn)者IllegalStateException由于第二次中止批次釋放
[ KAFKA-5959 ] - NetworkClient中的NPE
[ KAFKA-5960 ] - 生產(chǎn)者使用不受支持的ProduceRequest版本來(lái)對(duì)付老的經(jīng)紀(jì)人
[ KAFKA-5967 ] - CompositeReadOnlyKeyValueStore＃approximateNumEntries（）中的負(fù)值檢查無(wú)效
[ KAFKA-5968 ] - 關(guān)閉期間刪除所有經(jīng)紀(jì)人指標(biāo)
[ KAFKA-5970 ] - 由于DelayedProduce和組的鎖定而導(dǎo)致的死鎖
[ KAFKA-5976 ] - RequestChannel.sendReponse使用TRACE日志記錄記錄NetworkSend的大小不正確
[ KAFKA-5979 ] - kip-120改變了內(nèi)部流的主題命名
[ KAFKA-5980 ] - FailOnInvalidTimestamp不記錄錯(cuò)誤
[ KAFKA-5986 ] - 流狀態(tài)當(dāng)日志記錄被禁用時(shí)懂更，恢復(fù)永不完成
[ KAFKA-5989 ] - disableLogging（）會(huì)導(dǎo)致分區(qū)不被占用
[ KAFKA-5995 ] - 將AlterReplicaDir重命名為AlterReplicaDirs
[ KAFKA-6003 ] - 沒(méi)有數(shù)據(jù)的分區(qū)的復(fù)制提取程序線程無(wú)法啟動(dòng)
[ KAFKA-6005 ] - 拒絕來(lái)自具有空白協(xié)議類(lèi)型/協(xié)議列表的第一個(gè)成員的JoinGroup請(qǐng)求
[ KAFKA-6008 ] - Kafka Connect：未啟動(dòng)的workerID會(huì)在啟動(dòng)過(guò)程中導(dǎo)致異常
[ KAFKA-6010 ] - 瞬態(tài)故障：MemoryRecordsBuilderTest.convertToV1WithMixedV0AndV2Data
在TransactionBounceTest期間眨业，markErrorMeter中的NoSuchElementException異常[ KAFKA-6012 ]
[ KAFKA-6015 ] - RecordAccumulator中的NPE
[ KAFKA-6016 ] - 在reassign_partitions_test中使用冪等生產(chǎn)者
[ KAFKA-6026 ] - 如果遇到較窄的爭(zhēng)用條件，KafkaFuture超時(shí)將失敗
[ KAFKA-6027 ] - 系統(tǒng)測(cè)試失斁谛：LogDirFailureTest
[ KAFKA-6030 ] - 原木清理比例計(jì)算中的整數(shù)溢出
[ KAFKA-6042 ] - Kafka請(qǐng)求處理程序死鎖并關(guān)閉群集龄捡。
[ KAFKA-6053 ] - 在升級(jí)系統(tǒng)測(cè)試中創(chuàng)建ProducerRecord時(shí)出現(xiàn)NoSuchMethodError
[ KAFKA-6055 ] - Windows上的運(yùn)行工具由于JVM配置中的輸入錯(cuò)誤而失敗
[ KAFKA-6070 ] - ducker-ak：將ipaddress和enum34依賴(lài)添加到docker映像
[ KAFKA-6087 ] - 掃描插件。路徑需要支持相關(guān)的符號(hào)鏈接
[ KAFKA-6093 ] - 主題刪除后副本目錄未被刪除
[ KAFKA-6100 ] - 流快速入門(mén)在Windows上崩潰Java
[ KAFKA-6101 ] - 重新連接到經(jīng)紀(jì)人不會(huì)成指數(shù)退縮
[ KAFKA-6116 ] - 在領(lǐng)導(dǎo)選舉期間由于過(guò)度采伐造成的主要表現(xiàn)問(wèn)題
[ KAFKA-6119 ] - Kafka011事務(wù)性生產(chǎn)者的無(wú)聲數(shù)據(jù)丟失
[ KAFKA-6131 ] - 如果txns同時(shí)完成慷暂，事務(wù)標(biāo)記有時(shí)會(huì)被丟棄
[ KAFKA-6134 ] - 分區(qū)重新分配期間控制器上的內(nèi)存使用率高
任務(wù)

[ KAFKA-5708 ] - 更新杰克遜依賴(lài)（從2.8.5到2.9.x）
[ KAFKA-5884 ] - 在Java 9上運(yùn)行時(shí)啟用PowerMock測(cè)試
[ KAFKA-5977 ] - 將RocksDB依賴(lài)性升級(jí)到合法可接受的版本
測(cè)試

[ KAFKA-5742 ] - 支持在系統(tǒng)測(cè)試中通過(guò)ZK chroot
[ KAFKA-6104 ] - 為ClusterConnectionStates添加單元測(cè)試
子任務(wù)

[ KAFKA-2507 ] - 用org.apache.kafka.common.requests替換ControlledShutdown {Request聘殖，Response}
[ KAFKA-2959 ] - 刪除臨時(shí)映射以反序列化RequestChannel中的函數(shù)
[ KAFKA-4593 ] - 重新平衡回調(diào)過(guò)程中的任務(wù)遷移可能會(huì)導(dǎo)致已過(guò)時(shí)的任務(wù)IllegalStateException
[ KAFKA-4643 ] - 改進(jìn)StreamsKafkaClient的測(cè)試覆蓋率
[ KAFKA-4653 ] - 改進(jìn)RocksDBStore的測(cè)試覆蓋率
[ KAFKA-4655 ] - 改進(jìn)CompositeReadOnlySessionStore的測(cè)試覆蓋率
[ KAFKA-4656 ] - 改進(jìn)CompositeReadOnlyKeyValueStore的測(cè)試覆蓋率
[ KAFKA-4658 ] - 改進(jìn)測(cè)試覆蓋范圍InMemoryKeyValueLoggedStore
[ KAFKA-4659 ] - 改進(jìn)CachingKeyValueStore的測(cè)試覆蓋率
[ KAFKA-4661 ] - 提高測(cè)試覆蓋率UsePreviousTimeOnInvalidTimestamp
[ KAFKA-4868 ] - 優(yōu)化RocksDb配置以實(shí)現(xiàn)快速恢復(fù)/批量加載
[ KAFKA-5006 ] - KeyValueStore.put可能會(huì)拋出與當(dāng)前投入無(wú)關(guān)的異常
[ KAFKA-5134 ] - 用zkUtils.getChildren替換zkClient.getChildren方法
[ KAFKA-5157 ] - 在反序列化期間處理?yè)p壞數(shù)據(jù)的選項(xiàng)
[ KAFKA-5314 ] - 改善國(guó)有商店的異常處理
[ KAFKA-5342 ] - 區(qū)分事務(wù)性生產(chǎn)者的流產(chǎn)故障
[ KAFKA-5372 ] - 意外的狀態(tài)轉(zhuǎn)換死于PendingShutdown
[ KAFKA-5388 ] - 用相同的zkUtils方法替換zkClient.subscribe *更改方法
[ KAFKA-5389 ] - 用zkUtils.pathExists替換zkClient.exists方法
[ KAFKA-5391 ] - 用等效的zkUtils方法替換zkClient.delete *方法
[ KAFKA-5494 ] - 冪等生產(chǎn)者不應(yīng)該要求max.in.flight.requests.per.connection = 1
[ KAFKA-5501 ] - 引入異步ZookeeperClient
[ KAFKA-5531 ] - 檢查所有流測(cè)試中的異常處理
[ KAFKA-5597 ] - 自動(dòng)生成發(fā)件人發(fā)件人指標(biāo)
[ KAFKA-5650 ] - 為自定義存儲(chǔ)引擎提供一個(gè)簡(jiǎn)單的方法使用流式存儲(chǔ)（KIP-182）
[ KAFKA-5653 ] - 向KTable添加新的API方法
[ KAFKA-5654 ] - 向KGroupedStream添加新的API方法
[ KAFKA-5655 ] - 將新的API方法添加到KGroupedTable
[ KAFKA-5670 ] - 添加拓?fù)洳売猛負(fù)錁?gòu)建器
[ KAFKA-5671 ] - 添加StreamsBuilder并棄用KStreamBuilder
[ KAFKA-5673 ] - 重構(gòu)KeyValueStore層次結(jié)構(gòu)，以便MeteredKeyValueStore是最外層的存儲(chǔ)
[ KAFKA-5689 ] - 重構(gòu)WindowStore層次結(jié)構(gòu)行瑞，使Metered Store成為最外層的存儲(chǔ)區(qū)
[ KAFKA-5727 ] - 添加原型項(xiàng)目以及“編寫(xiě)應(yīng)用程序”的Web文檔奸腺。
[ KAFKA-5749 ] - 重構(gòu)SessionStore層次結(jié)構(gòu)
[ KAFKA-5776 ] - 添加Trogdor故障注入守護(hù)進(jìn)程
[ KAFKA-5777 ] - 為T(mén)rogdor Fault注入守護(hù)進(jìn)程添加ducktape集成
[ KAFKA-5793 ] - 加強(qiáng)可能返回OutOfOrderSequence的情況
[ KAFKA-5806 ] - 修復(fù)trogdor協(xié)調(diào)器關(guān)閉時(shí)的瞬態(tài)單元測(cè)試失敗
[ KAFKA-5815 ] - 添加打印類(lèi)和KStream＃打印（打友谩）
[ KAFKA-5816 ] - 向KStream添加生產(chǎn)類(lèi)和新的重載
[ KAFKA-5817 ] - 添加序列化類(lèi)和KStream groupBy和groupByKey重載
[ KAFKA-5819 ] - 添加連接類(lèi)和相關(guān)的KStream連接重載
[ KAFKA-5823 ] - 更新文件
[ KAFKA-5832 ] - 將消費(fèi)類(lèi)和重載添加到StreamBuilder
[ KAFKA-5839 ] - 升級(jí)指南doc更改為KIP-130
[ KAFKA-5844 ] - 將groupBy（KeyValueMapper突照，序列化）添加到KTable
[ KAFKA-5852 ] - 添加過(guò)濾器，filterNot氧吐，mapValues和Materialized到KTable
[ KAFKA-5853 ] - 添加WindowedKStream接口和實(shí)現(xiàn)
[ KAFKA-5873 ] - 將物化重載添加到StreamBuilder
[ KAFKA-5888 ] - 事務(wù)系統(tǒng)測(cè)試應(yīng)檢查消息順序
[ KAFKA-5899 ] - 為連接器創(chuàng)建連接度量標(biāo)準(zhǔn)
[ KAFKA-5900 ] - 創(chuàng)建源和匯任務(wù)通用的連接度量標(biāo)準(zhǔn)
[ KAFKA-5901 ] - 為源任務(wù)創(chuàng)建連接度量標(biāo)準(zhǔn)
[ KAFKA-5902 ] - 為信宿任務(wù)創(chuàng)建連接度量標(biāo)準(zhǔn)
[ KAFKA-5903 ] - 為工作人員創(chuàng)建連接度量標(biāo)準(zhǔn)
[ KAFKA-5904 ] - 為員工重新平衡創(chuàng)建連接度量標(biāo)準(zhǔn)
[ KAFKA-5913 ] - 將“hasOffset”和“hasTimestamp”方法添加到RecordMetadata中讹蘑，以指示元數(shù)據(jù)是否可用
[ KAFKA-5921 ] - 將物化過(guò)載添加到WindowedKStream
[ KAFKA-5922 ] - 添加SessionWindowedKStream
[ KAFKA-5931 ] - 棄用KTable＃to和KTable＃through
[ KAFKA-5937 ] - 改進(jìn)ProcessorStateManager異常處理
[ KAFKA-5949 ] - 用戶回調(diào)異常需要妥善處理
[ KAFKA-5990 ] - 為連接指標(biāo)添加生成的文檔