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 |
参照
詳細は、下記のサイトを参照してください。