ページの先頭行へ戻る
Big Data Integration ServerV1.2.0 リリース情報
FUJITSU Software

2.1.2 Apache Kafkaに関する非互換

Apache Kafkaに関する非互換を以下に示します。

代表的な事例

詳細

JIRA

Summary

コマンド仕様の変更

実行結果

KAFKA-6290

Kafka Connect cast transformation should support logical types

KAFKA-6605

Flatten SMT does not properly handle fields that are null

KAFKA-7157

Connect TimestampConverter SMT doesn't handle null values

KAFKA-7263

Container exception java.lang.IllegalStateException: Coordinator selected invalid assignment protocol: null

KAFKA-7487

DumpLogSegments reports mismatches for indexed offsets which are not at the start of a record batch

KAFKA-8229

Connect Sink Task updates nextCommit when commitRequest is true

KAFKA-8313

KafkaStreams state not being updated properly after shutdown

KAFKA-8400

Do not update follower replica state if the log read failed

KAFKA-8442

Inconsistent ISR output in topic command when using --bootstrap-server

KAFKA-8595

Support SerDe of Decimals in JSON that are not HEX encoded

KAFKA-8644

The Kafka protocol generator should allow null defaults for bytes and array fields

KAFKA-8676

Avoid Stopping Unnecessary Connectors and Tasks

KAFKA-8731

InMemorySessionStore throws NullPointerException on startup

KAFKA-8774

Connect REST API exposes plaintext secrets in tasks endpoint if config value contains additional characters

KAFKA-8857

Config describe should not return isReadOnly=false based on synonyms

KAFKA-8875

CreateTopic API should check topic existence before replication factor

KAFKA-8892

Display the sorted configs in Kafka Configs Help Command.

KAFKA-8983

AdminClient deleteRecords should not fail all partitions unnecessarily

例外処理修正

KAFKA-8884

Improve streams errors on class cast exception in ProcessorsNodes

例外処理追加

KAFKA-8678

LeaveGroup request getErrorResponse is incorrect on throttle time and error setting

KAFKA-8725

Improve LogCleaner error handling when failing to grab the filthiest log

機能統合

KAFKA-8696

Clean up Sum/Count/Total metrics

チェック強化

チェック強化

KAFKA-8945

Incorrect null check in the constructor for ConnectorHealth and AbstractState

公開しているファイルの内容/形式

ログ修正

KAFKA-5609

Connect log4j should log to file by default

KAFKA-7986

distinguish the logging from different ZooKeeperClient instances

KAFKA-8839

Improve logging in Kafka Streams around debugging task lifecycle

ログ頻度

KAFKA-7321

ensure timely processing of deletion requests in Kafka topic (Time-based log compaction)

KAFKA-7772

Dynamically adjust log level in Connect workers

ドキュメント修正

KAFKA-8984

Improve tagged fields documentation

メッセージ

メッセージ修正

KAFKA-7601

Handle message format downgrades during upgrade of message format version

KAFKA-5998

/.checkpoint.tmp Not found exception

KAFKA-7849

Warning when adding GlobalKTable

KAFKA-8053

kafka-topics.sh gives confusing error message when the topic doesn't exist

KAFKA-8062

StateListener is not notified when StreamThread dies

KAFKA-8745

DumpLogSegments doesn't show keys, when the message is null

メッセージ削除

KAFKA-8501

Remove key and value from exception message

非推奨機能

非推奨削除

KAFKA-8514

Kafka clients should not include Scala's Java 8 compatibility lib

KAFKA-8544

Remove legacy kafka.admin.AdminClient

KAFKA-8545

Remove legacy ZkUtils

KAFKA-8563

Minor: Remove method call in networkSend. Rely on java's vargs boxing/autoboxing

KAFKA-8927

Remove config `partition.grouper` and interface `PartitionGrouper`

非推奨追加

KAFKA-8880

Augment Consumer.committed(partition) to allow multiple partitions

使用メモリの増加

KAFKA-8029

Add in-memory bytes-only session store implementation

KAFKA-8488

FetchSessionHandler logging create 73 mb allocation in TLAB which could be no op

KAFKA-8559

PartitionStates.partitionStates cause array grow allocation.

誤った実装の修正

KAFKA-8954

Topic existence check is wrongly implemented in the DeleteOffset API

参照

詳細は、下記のサイトを参照してください。

https://issues.apache.org/jira/secure/Dashboard.jspa