mimaison commented on code in PR #547: URL: https://github.com/apache/kafka-site/pull/547#discussion_r1347093948
########## blog.html: ########## @@ -39,35 +39,35 @@ <h2 class="bullet"> for details regarding KRaft and JBOD. </p> <p>Support for Delegation Tokens in KRaft (<a href="https://issues.apache.org/jira/browse/KAFKA-15219";>KAFKA-15219</a>) was completed in 3.6, further reducing the gap of features between ZooKeeper-based Kafka clusters and KRaft. Migration of delegation tokens from ZooKeeper to KRaft is also included in 3.6.</p> - <p><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-405%3A+Kafka+Tiered+Storage";>Tiered Storage<a> is an early access feature. It is currently only suitable for testing in non production environments. See <a href="https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Tiered+Storage+Early+Access+Release+Notes";>Early Access Notes</a> for more details.</p> + <p><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-405%3A+Kafka+Tiered+Storage";>Tiered Storage</a> is an early access feature. It is currently only suitable for testing in non production environments. See <a href="https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Tiered+Storage+Early+Access+Release+Notes";>Early Access Notes</a> for more details.</p> <p><i>Note: ZooKeeper is marked as deprecated since 3.5.0 release. ZooKeeper is planned to be removed in Apache Kafka 4.0. (Cf <a href="/documentation#zk_depr">ZooKeeper Deprecation</a>)</i><p> <h3>Kafka Broker, Controller, Producer, Consumer and Admin Client</h3> <ul> - <li><b>KIP-405: Kafka Tiered Storage</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-405%3A+Kafka+Tiered+Storage";>KIP-405</a>. It introduces tiered storage feature in Kafka that provides separation of computation and storage in the broker.</li> - <li><b>KIP-797: Accept duplicate listener on port for IPv4/IPv6</b><a href="https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=195726330";>KIP-797</a>. Brokers can be configured with listeners that have same port on different ip stack like ipv4 and ipv6.</li> - <li><b>KIP-863: Reduce CompletedFetch#parseRecord() memory copy</b><a href="https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=225152035";>KIP-863</a>. Reduced CompletedFetch#parseRecord() memory copy by deserializing using byte buffers.</li> - <li><b>KIP-868: Metadata Transactions</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-868+Metadata+Transactions";>KIP-868</a>. This feature is about allowing the controller to generate atomic transactions of records that can exceed the maximum batch size.</li> - <li><b>KIP-902: Upgrade Zookeeper to 3.8.2</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-902%3A+Upgrade+Zookeeper+to+3.8.2";>KIP-902</a>. Zookeeper client upgraded to 3.8.2 version as the current zookeeper dependency version 3.6.3 reached the end of life.</li> - <li><b>KIP-917: Additional custom metadata for remote log segment</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-917%3A+Additional+custom+metadata+for+remote+log+segment";>KIP-917</a>. Custom metedata support for remote log segments.</li> - <li><b>KIP-930: Rename ambiguous Tiered Storage Metrics</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-930%3A+Rename+ambiguous+Tiered+Storage+Metrics";>KIP-930</a>. Renamed ambiguous tiered storage metrics.</li> - <li><b>KIP-937: Improve Message Timestamp Validation</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-937%3A+Improve+Message+Timestamp+Validation";>KIP-937</a>. Improved Producer's record timestamp validation.</li> - <li><b>KIP-938: Add more metrics for measuring KRaft performance</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-938%3A+Add+more+metrics+for+measuring+KRaft+performance";>KIP-938</a>. Added the targeted KRaft performance metrics mentioned in KIP-938 except ForwardingManager metrics.</li> + <li><b>KIP-405: Kafka Tiered Storage: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-405%3A+Kafka+Tiered+Storage";>KIP-405</a>. It introduces tiered storage feature in Kafka that provides separation of computation and storage in the broker.</li> + <li><b>KIP-797: Accept duplicate listener on port for IPv4/IPv6: </b><a href="https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=195726330";>KIP-797</a>. Brokers can be configured with listeners that have same port on different ip stack like ipv4 and ipv6.</li> + <li><b>KIP-863: Reduce CompletedFetch#parseRecord() memory copy: </b><a href="https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=225152035";>KIP-863</a>. Reduced CompletedFetch#parseRecord() memory copy by deserializing using byte buffers.</li> + <li><b>KIP-868: Metadata Transactions: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-868+Metadata+Transactions";>KIP-868</a>. This feature is about allowing the controller to generate atomic transactions of records that can exceed the maximum batch size.</li> + <li><b>KIP-902: Upgrade Zookeeper to 3.8.2: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-902%3A+Upgrade+Zookeeper+to+3.8.2";>KIP-902</a>. Zookeeper client upgraded to 3.8.2 version as the current Zookeeper dependency version 3.6.3 reached the end of life.</li> + <li><b>KIP-917: Additional custom metadata for remote log segment: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-917%3A+Additional+custom+metadata+for+remote+log+segment";>KIP-917</a>. Custom metedata support for remote log segments.</li> + <li><b>KIP-930: Rename ambiguous Tiered Storage Metrics: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-930%3A+Rename+ambiguous+Tiered+Storage+Metrics";>KIP-930</a>. Renamed ambiguous tiered storage metrics.</li> + <li><b>KIP-937: Improve Message Timestamp Validation: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-937%3A+Improve+Message+Timestamp+Validation";>KIP-937</a>. Improved Producer's record timestamp validation.</li> + <li><b>KIP-938: Add more metrics for measuring KRaft performance: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-938%3A+Add+more+metrics+for+measuring+KRaft+performance";>KIP-938</a>. Added the targeted KRaft performance metrics mentioned in KIP-938 except ForwardingManager metrics.</li> </ul> <h3>Kafka Streams</h3> <ul> - <li><b>KIP-923: Add A Grace Period to Stream Table Join</b>: <a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-923%3A+Add+A+Grace+Period+to+Stream+Table+Join";>KIP-923</a>Added a grace period to Stream Table join.</li> - <li><b>KIP-941: Range queries to accept null lower and upper bounds</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-941%3A+Range+queries+to+accept+null+lower+and+upper+bounds";>KIP-941</a> Range queries accept lower and upper bounds as null values.</li> + <li><b>KIP-923: Add A Grace Period to Stream Table Join: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-923%3A+Add+A+Grace+Period+to+Stream+Table+Join";>KIP-923</a>Added a grace period to Stream Table join.</li> Review Comment: We're missing a space (and dot) between `KIP-923` and `Added` ########## blog.html: ########## @@ -39,35 +39,35 @@ <h2 class="bullet"> for details regarding KRaft and JBOD. </p> <p>Support for Delegation Tokens in KRaft (<a href="https://issues.apache.org/jira/browse/KAFKA-15219";>KAFKA-15219</a>) was completed in 3.6, further reducing the gap of features between ZooKeeper-based Kafka clusters and KRaft. Migration of delegation tokens from ZooKeeper to KRaft is also included in 3.6.</p> - <p><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-405%3A+Kafka+Tiered+Storage";>Tiered Storage<a> is an early access feature. It is currently only suitable for testing in non production environments. See <a href="https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Tiered+Storage+Early+Access+Release+Notes";>Early Access Notes</a> for more details.</p> + <p><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-405%3A+Kafka+Tiered+Storage";>Tiered Storage</a> is an early access feature. It is currently only suitable for testing in non production environments. See <a href="https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Tiered+Storage+Early+Access+Release+Notes";>Early Access Notes</a> for more details.</p> <p><i>Note: ZooKeeper is marked as deprecated since 3.5.0 release. ZooKeeper is planned to be removed in Apache Kafka 4.0. (Cf <a href="/documentation#zk_depr">ZooKeeper Deprecation</a>)</i><p> <h3>Kafka Broker, Controller, Producer, Consumer and Admin Client</h3> <ul> - <li><b>KIP-405: Kafka Tiered Storage</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-405%3A+Kafka+Tiered+Storage";>KIP-405</a>. It introduces tiered storage feature in Kafka that provides separation of computation and storage in the broker.</li> - <li><b>KIP-797: Accept duplicate listener on port for IPv4/IPv6</b><a href="https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=195726330";>KIP-797</a>. Brokers can be configured with listeners that have same port on different ip stack like ipv4 and ipv6.</li> - <li><b>KIP-863: Reduce CompletedFetch#parseRecord() memory copy</b><a href="https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=225152035";>KIP-863</a>. Reduced CompletedFetch#parseRecord() memory copy by deserializing using byte buffers.</li> - <li><b>KIP-868: Metadata Transactions</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-868+Metadata+Transactions";>KIP-868</a>. This feature is about allowing the controller to generate atomic transactions of records that can exceed the maximum batch size.</li> - <li><b>KIP-902: Upgrade Zookeeper to 3.8.2</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-902%3A+Upgrade+Zookeeper+to+3.8.2";>KIP-902</a>. Zookeeper client upgraded to 3.8.2 version as the current zookeeper dependency version 3.6.3 reached the end of life.</li> - <li><b>KIP-917: Additional custom metadata for remote log segment</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-917%3A+Additional+custom+metadata+for+remote+log+segment";>KIP-917</a>. Custom metedata support for remote log segments.</li> - <li><b>KIP-930: Rename ambiguous Tiered Storage Metrics</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-930%3A+Rename+ambiguous+Tiered+Storage+Metrics";>KIP-930</a>. Renamed ambiguous tiered storage metrics.</li> - <li><b>KIP-937: Improve Message Timestamp Validation</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-937%3A+Improve+Message+Timestamp+Validation";>KIP-937</a>. Improved Producer's record timestamp validation.</li> - <li><b>KIP-938: Add more metrics for measuring KRaft performance</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-938%3A+Add+more+metrics+for+measuring+KRaft+performance";>KIP-938</a>. Added the targeted KRaft performance metrics mentioned in KIP-938 except ForwardingManager metrics.</li> + <li><b>KIP-405: Kafka Tiered Storage: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-405%3A+Kafka+Tiered+Storage";>KIP-405</a>. It introduces tiered storage feature in Kafka that provides separation of computation and storage in the broker.</li> + <li><b>KIP-797: Accept duplicate listener on port for IPv4/IPv6: </b><a href="https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=195726330";>KIP-797</a>. Brokers can be configured with listeners that have same port on different ip stack like ipv4 and ipv6.</li> + <li><b>KIP-863: Reduce CompletedFetch#parseRecord() memory copy: </b><a href="https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=225152035";>KIP-863</a>. Reduced CompletedFetch#parseRecord() memory copy by deserializing using byte buffers.</li> + <li><b>KIP-868: Metadata Transactions: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-868+Metadata+Transactions";>KIP-868</a>. This feature is about allowing the controller to generate atomic transactions of records that can exceed the maximum batch size.</li> + <li><b>KIP-902: Upgrade Zookeeper to 3.8.2: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-902%3A+Upgrade+Zookeeper+to+3.8.2";>KIP-902</a>. Zookeeper client upgraded to 3.8.2 version as the current Zookeeper dependency version 3.6.3 reached the end of life.</li> + <li><b>KIP-917: Additional custom metadata for remote log segment: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-917%3A+Additional+custom+metadata+for+remote+log+segment";>KIP-917</a>. Custom metedata support for remote log segments.</li> Review Comment: What about `This allows <code>RemoteStorageManager</code> implementation to attach custom metadata to remote log segments that can be used by storage systems to adjust the way they are stored.`? ########## blog.html: ########## @@ -39,35 +39,35 @@ <h2 class="bullet"> for details regarding KRaft and JBOD. </p> <p>Support for Delegation Tokens in KRaft (<a href="https://issues.apache.org/jira/browse/KAFKA-15219";>KAFKA-15219</a>) was completed in 3.6, further reducing the gap of features between ZooKeeper-based Kafka clusters and KRaft. Migration of delegation tokens from ZooKeeper to KRaft is also included in 3.6.</p> - <p><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-405%3A+Kafka+Tiered+Storage";>Tiered Storage<a> is an early access feature. It is currently only suitable for testing in non production environments. See <a href="https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Tiered+Storage+Early+Access+Release+Notes";>Early Access Notes</a> for more details.</p> + <p><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-405%3A+Kafka+Tiered+Storage";>Tiered Storage</a> is an early access feature. It is currently only suitable for testing in non production environments. See <a href="https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Tiered+Storage+Early+Access+Release+Notes";>Early Access Notes</a> for more details.</p> <p><i>Note: ZooKeeper is marked as deprecated since 3.5.0 release. ZooKeeper is planned to be removed in Apache Kafka 4.0. (Cf <a href="/documentation#zk_depr">ZooKeeper Deprecation</a>)</i><p> <h3>Kafka Broker, Controller, Producer, Consumer and Admin Client</h3> <ul> - <li><b>KIP-405: Kafka Tiered Storage</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-405%3A+Kafka+Tiered+Storage";>KIP-405</a>. It introduces tiered storage feature in Kafka that provides separation of computation and storage in the broker.</li> - <li><b>KIP-797: Accept duplicate listener on port for IPv4/IPv6</b><a href="https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=195726330";>KIP-797</a>. Brokers can be configured with listeners that have same port on different ip stack like ipv4 and ipv6.</li> - <li><b>KIP-863: Reduce CompletedFetch#parseRecord() memory copy</b><a href="https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=225152035";>KIP-863</a>. Reduced CompletedFetch#parseRecord() memory copy by deserializing using byte buffers.</li> - <li><b>KIP-868: Metadata Transactions</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-868+Metadata+Transactions";>KIP-868</a>. This feature is about allowing the controller to generate atomic transactions of records that can exceed the maximum batch size.</li> - <li><b>KIP-902: Upgrade Zookeeper to 3.8.2</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-902%3A+Upgrade+Zookeeper+to+3.8.2";>KIP-902</a>. Zookeeper client upgraded to 3.8.2 version as the current zookeeper dependency version 3.6.3 reached the end of life.</li> - <li><b>KIP-917: Additional custom metadata for remote log segment</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-917%3A+Additional+custom+metadata+for+remote+log+segment";>KIP-917</a>. Custom metedata support for remote log segments.</li> - <li><b>KIP-930: Rename ambiguous Tiered Storage Metrics</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-930%3A+Rename+ambiguous+Tiered+Storage+Metrics";>KIP-930</a>. Renamed ambiguous tiered storage metrics.</li> - <li><b>KIP-937: Improve Message Timestamp Validation</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-937%3A+Improve+Message+Timestamp+Validation";>KIP-937</a>. Improved Producer's record timestamp validation.</li> - <li><b>KIP-938: Add more metrics for measuring KRaft performance</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-938%3A+Add+more+metrics+for+measuring+KRaft+performance";>KIP-938</a>. Added the targeted KRaft performance metrics mentioned in KIP-938 except ForwardingManager metrics.</li> + <li><b>KIP-405: Kafka Tiered Storage: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-405%3A+Kafka+Tiered+Storage";>KIP-405</a>. It introduces tiered storage feature in Kafka that provides separation of computation and storage in the broker.</li> + <li><b>KIP-797: Accept duplicate listener on port for IPv4/IPv6: </b><a href="https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=195726330";>KIP-797</a>. Brokers can be configured with listeners that have same port on different ip stack like ipv4 and ipv6.</li> + <li><b>KIP-863: Reduce CompletedFetch#parseRecord() memory copy: </b><a href="https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=225152035";>KIP-863</a>. Reduced CompletedFetch#parseRecord() memory copy by deserializing using byte buffers.</li> Review Comment: What about: `This reduces the memory usage of consumers by avoiding making copies in Deserializers.`? ########## blog.html: ########## @@ -39,35 +39,35 @@ <h2 class="bullet"> for details regarding KRaft and JBOD. </p> <p>Support for Delegation Tokens in KRaft (<a href="https://issues.apache.org/jira/browse/KAFKA-15219";>KAFKA-15219</a>) was completed in 3.6, further reducing the gap of features between ZooKeeper-based Kafka clusters and KRaft. Migration of delegation tokens from ZooKeeper to KRaft is also included in 3.6.</p> - <p><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-405%3A+Kafka+Tiered+Storage";>Tiered Storage<a> is an early access feature. It is currently only suitable for testing in non production environments. See <a href="https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Tiered+Storage+Early+Access+Release+Notes";>Early Access Notes</a> for more details.</p> + <p><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-405%3A+Kafka+Tiered+Storage";>Tiered Storage</a> is an early access feature. It is currently only suitable for testing in non production environments. See <a href="https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Tiered+Storage+Early+Access+Release+Notes";>Early Access Notes</a> for more details.</p> <p><i>Note: ZooKeeper is marked as deprecated since 3.5.0 release. ZooKeeper is planned to be removed in Apache Kafka 4.0. (Cf <a href="/documentation#zk_depr">ZooKeeper Deprecation</a>)</i><p> <h3>Kafka Broker, Controller, Producer, Consumer and Admin Client</h3> <ul> - <li><b>KIP-405: Kafka Tiered Storage</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-405%3A+Kafka+Tiered+Storage";>KIP-405</a>. It introduces tiered storage feature in Kafka that provides separation of computation and storage in the broker.</li> - <li><b>KIP-797: Accept duplicate listener on port for IPv4/IPv6</b><a href="https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=195726330";>KIP-797</a>. Brokers can be configured with listeners that have same port on different ip stack like ipv4 and ipv6.</li> - <li><b>KIP-863: Reduce CompletedFetch#parseRecord() memory copy</b><a href="https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=225152035";>KIP-863</a>. Reduced CompletedFetch#parseRecord() memory copy by deserializing using byte buffers.</li> - <li><b>KIP-868: Metadata Transactions</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-868+Metadata+Transactions";>KIP-868</a>. This feature is about allowing the controller to generate atomic transactions of records that can exceed the maximum batch size.</li> - <li><b>KIP-902: Upgrade Zookeeper to 3.8.2</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-902%3A+Upgrade+Zookeeper+to+3.8.2";>KIP-902</a>. Zookeeper client upgraded to 3.8.2 version as the current zookeeper dependency version 3.6.3 reached the end of life.</li> - <li><b>KIP-917: Additional custom metadata for remote log segment</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-917%3A+Additional+custom+metadata+for+remote+log+segment";>KIP-917</a>. Custom metedata support for remote log segments.</li> - <li><b>KIP-930: Rename ambiguous Tiered Storage Metrics</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-930%3A+Rename+ambiguous+Tiered+Storage+Metrics";>KIP-930</a>. Renamed ambiguous tiered storage metrics.</li> - <li><b>KIP-937: Improve Message Timestamp Validation</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-937%3A+Improve+Message+Timestamp+Validation";>KIP-937</a>. Improved Producer's record timestamp validation.</li> - <li><b>KIP-938: Add more metrics for measuring KRaft performance</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-938%3A+Add+more+metrics+for+measuring+KRaft+performance";>KIP-938</a>. Added the targeted KRaft performance metrics mentioned in KIP-938 except ForwardingManager metrics.</li> + <li><b>KIP-405: Kafka Tiered Storage: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-405%3A+Kafka+Tiered+Storage";>KIP-405</a>. It introduces tiered storage feature in Kafka that provides separation of computation and storage in the broker.</li> + <li><b>KIP-797: Accept duplicate listener on port for IPv4/IPv6: </b><a href="https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=195726330";>KIP-797</a>. Brokers can be configured with listeners that have same port on different ip stack like ipv4 and ipv6.</li> + <li><b>KIP-863: Reduce CompletedFetch#parseRecord() memory copy: </b><a href="https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=225152035";>KIP-863</a>. Reduced CompletedFetch#parseRecord() memory copy by deserializing using byte buffers.</li> + <li><b>KIP-868: Metadata Transactions: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-868+Metadata+Transactions";>KIP-868</a>. This feature is about allowing the controller to generate atomic transactions of records that can exceed the maximum batch size.</li> + <li><b>KIP-902: Upgrade Zookeeper to 3.8.2: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-902%3A+Upgrade+Zookeeper+to+3.8.2";>KIP-902</a>. Zookeeper client upgraded to 3.8.2 version as the current Zookeeper dependency version 3.6.3 reached the end of life.</li> + <li><b>KIP-917: Additional custom metadata for remote log segment: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-917%3A+Additional+custom+metadata+for+remote+log+segment";>KIP-917</a>. Custom metedata support for remote log segments.</li> + <li><b>KIP-930: Rename ambiguous Tiered Storage Metrics: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-930%3A+Rename+ambiguous+Tiered+Storage+Metrics";>KIP-930</a>. Renamed ambiguous tiered storage metrics.</li> + <li><b>KIP-937: Improve Message Timestamp Validation: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-937%3A+Improve+Message+Timestamp+Validation";>KIP-937</a>. Improved Producer's record timestamp validation.</li> + <li><b>KIP-938: Add more metrics for measuring KRaft performance: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-938%3A+Add+more+metrics+for+measuring+KRaft+performance";>KIP-938</a>. Added the targeted KRaft performance metrics mentioned in KIP-938 except ForwardingManager metrics.</li> </ul> <h3>Kafka Streams</h3> <ul> - <li><b>KIP-923: Add A Grace Period to Stream Table Join</b>: <a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-923%3A+Add+A+Grace+Period+to+Stream+Table+Join";>KIP-923</a>Added a grace period to Stream Table join.</li> - <li><b>KIP-941: Range queries to accept null lower and upper bounds</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-941%3A+Range+queries+to+accept+null+lower+and+upper+bounds";>KIP-941</a> Range queries accept lower and upper bounds as null values.</li> + <li><b>KIP-923: Add A Grace Period to Stream Table Join: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-923%3A+Add+A+Grace+Period+to+Stream+Table+Join";>KIP-923</a>Added a grace period to Stream Table join.</li> + <li><b>KIP-941: Range queries to accept null lower and upper bounds: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-941%3A+Range+queries+to+accept+null+lower+and+upper+bounds";>KIP-941</a> Range queries accept lower and upper bounds as null values.</li> </ul> <h3>Kafka Connect</h3> <ul> - <li><b>KIP-793: Allow sink connectors to be used with topic-mutating SMTs</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-793%3A+Allow+sink+connectors+to+be+used+with+topic-mutating+SMTs";>KIP-793</a>. It supports topic-mutating SMTs for async sink connectors.</li> - <li><b>KIP-875: First-class offsets support in Kafka Connect</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-875%3A+First-class+offsets+support+in+Kafka+Connect";>KIP-875</a>. Kafka Connect supports offset reset.</li> - <li><b>KIP-898: Modernize Connect plugin discovery</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-898%3A+Modernize+Connect+plugin+discovery";>KIP-898</a>.The worker will read plugin classes from ServiceLoader manifests and module info during startup.</li> + <li><b>KIP-793: Allow sink connectors to be used with topic-mutating SMTs: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-793%3A+Allow+sink+connectors+to+be+used+with+topic-mutating+SMTs";>KIP-793</a>. It supports topic-mutating SMTs for async sink connectors.</li> Review Comment: What about: `This allows transformations that update the topic of records to be used with sink connectors that use their own mechanism to track offsets.`? ########## blog.html: ########## @@ -39,35 +39,35 @@ <h2 class="bullet"> for details regarding KRaft and JBOD. </p> <p>Support for Delegation Tokens in KRaft (<a href="https://issues.apache.org/jira/browse/KAFKA-15219";>KAFKA-15219</a>) was completed in 3.6, further reducing the gap of features between ZooKeeper-based Kafka clusters and KRaft. Migration of delegation tokens from ZooKeeper to KRaft is also included in 3.6.</p> - <p><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-405%3A+Kafka+Tiered+Storage";>Tiered Storage<a> is an early access feature. It is currently only suitable for testing in non production environments. See <a href="https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Tiered+Storage+Early+Access+Release+Notes";>Early Access Notes</a> for more details.</p> + <p><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-405%3A+Kafka+Tiered+Storage";>Tiered Storage</a> is an early access feature. It is currently only suitable for testing in non production environments. See <a href="https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Tiered+Storage+Early+Access+Release+Notes";>Early Access Notes</a> for more details.</p> <p><i>Note: ZooKeeper is marked as deprecated since 3.5.0 release. ZooKeeper is planned to be removed in Apache Kafka 4.0. (Cf <a href="/documentation#zk_depr">ZooKeeper Deprecation</a>)</i><p> <h3>Kafka Broker, Controller, Producer, Consumer and Admin Client</h3> <ul> - <li><b>KIP-405: Kafka Tiered Storage</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-405%3A+Kafka+Tiered+Storage";>KIP-405</a>. It introduces tiered storage feature in Kafka that provides separation of computation and storage in the broker.</li> - <li><b>KIP-797: Accept duplicate listener on port for IPv4/IPv6</b><a href="https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=195726330";>KIP-797</a>. Brokers can be configured with listeners that have same port on different ip stack like ipv4 and ipv6.</li> - <li><b>KIP-863: Reduce CompletedFetch#parseRecord() memory copy</b><a href="https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=225152035";>KIP-863</a>. Reduced CompletedFetch#parseRecord() memory copy by deserializing using byte buffers.</li> - <li><b>KIP-868: Metadata Transactions</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-868+Metadata+Transactions";>KIP-868</a>. This feature is about allowing the controller to generate atomic transactions of records that can exceed the maximum batch size.</li> - <li><b>KIP-902: Upgrade Zookeeper to 3.8.2</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-902%3A+Upgrade+Zookeeper+to+3.8.2";>KIP-902</a>. Zookeeper client upgraded to 3.8.2 version as the current zookeeper dependency version 3.6.3 reached the end of life.</li> - <li><b>KIP-917: Additional custom metadata for remote log segment</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-917%3A+Additional+custom+metadata+for+remote+log+segment";>KIP-917</a>. Custom metedata support for remote log segments.</li> - <li><b>KIP-930: Rename ambiguous Tiered Storage Metrics</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-930%3A+Rename+ambiguous+Tiered+Storage+Metrics";>KIP-930</a>. Renamed ambiguous tiered storage metrics.</li> - <li><b>KIP-937: Improve Message Timestamp Validation</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-937%3A+Improve+Message+Timestamp+Validation";>KIP-937</a>. Improved Producer's record timestamp validation.</li> - <li><b>KIP-938: Add more metrics for measuring KRaft performance</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-938%3A+Add+more+metrics+for+measuring+KRaft+performance";>KIP-938</a>. Added the targeted KRaft performance metrics mentioned in KIP-938 except ForwardingManager metrics.</li> + <li><b>KIP-405: Kafka Tiered Storage: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-405%3A+Kafka+Tiered+Storage";>KIP-405</a>. It introduces tiered storage feature in Kafka that provides separation of computation and storage in the broker.</li> + <li><b>KIP-797: Accept duplicate listener on port for IPv4/IPv6: </b><a href="https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=195726330";>KIP-797</a>. Brokers can be configured with listeners that have same port on different ip stack like ipv4 and ipv6.</li> + <li><b>KIP-863: Reduce CompletedFetch#parseRecord() memory copy: </b><a href="https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=225152035";>KIP-863</a>. Reduced CompletedFetch#parseRecord() memory copy by deserializing using byte buffers.</li> + <li><b>KIP-868: Metadata Transactions: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-868+Metadata+Transactions";>KIP-868</a>. This feature is about allowing the controller to generate atomic transactions of records that can exceed the maximum batch size.</li> + <li><b>KIP-902: Upgrade Zookeeper to 3.8.2: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-902%3A+Upgrade+Zookeeper+to+3.8.2";>KIP-902</a>. Zookeeper client upgraded to 3.8.2 version as the current Zookeeper dependency version 3.6.3 reached the end of life.</li> + <li><b>KIP-917: Additional custom metadata for remote log segment: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-917%3A+Additional+custom+metadata+for+remote+log+segment";>KIP-917</a>. Custom metedata support for remote log segments.</li> + <li><b>KIP-930: Rename ambiguous Tiered Storage Metrics: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-930%3A+Rename+ambiguous+Tiered+Storage+Metrics";>KIP-930</a>. Renamed ambiguous tiered storage metrics.</li> + <li><b>KIP-937: Improve Message Timestamp Validation: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-937%3A+Improve+Message+Timestamp+Validation";>KIP-937</a>. Improved Producer's record timestamp validation.</li> + <li><b>KIP-938: Add more metrics for measuring KRaft performance: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-938%3A+Add+more+metrics+for+measuring+KRaft+performance";>KIP-938</a>. Added the targeted KRaft performance metrics mentioned in KIP-938 except ForwardingManager metrics.</li> </ul> <h3>Kafka Streams</h3> <ul> - <li><b>KIP-923: Add A Grace Period to Stream Table Join</b>: <a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-923%3A+Add+A+Grace+Period+to+Stream+Table+Join";>KIP-923</a>Added a grace period to Stream Table join.</li> - <li><b>KIP-941: Range queries to accept null lower and upper bounds</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-941%3A+Range+queries+to+accept+null+lower+and+upper+bounds";>KIP-941</a> Range queries accept lower and upper bounds as null values.</li> + <li><b>KIP-923: Add A Grace Period to Stream Table Join: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-923%3A+Add+A+Grace+Period+to+Stream+Table+Join";>KIP-923</a>Added a grace period to Stream Table join.</li> + <li><b>KIP-941: Range queries to accept null lower and upper bounds: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-941%3A+Range+queries+to+accept+null+lower+and+upper+bounds";>KIP-941</a> Range queries accept lower and upper bounds as null values.</li> Review Comment: What about using `This simplifies making range queries using only an upper or lower bound` for the description? ########## blog.html: ########## @@ -39,35 +39,35 @@ <h2 class="bullet"> for details regarding KRaft and JBOD. </p> <p>Support for Delegation Tokens in KRaft (<a href="https://issues.apache.org/jira/browse/KAFKA-15219";>KAFKA-15219</a>) was completed in 3.6, further reducing the gap of features between ZooKeeper-based Kafka clusters and KRaft. Migration of delegation tokens from ZooKeeper to KRaft is also included in 3.6.</p> - <p><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-405%3A+Kafka+Tiered+Storage";>Tiered Storage<a> is an early access feature. It is currently only suitable for testing in non production environments. See <a href="https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Tiered+Storage+Early+Access+Release+Notes";>Early Access Notes</a> for more details.</p> + <p><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-405%3A+Kafka+Tiered+Storage";>Tiered Storage</a> is an early access feature. It is currently only suitable for testing in non production environments. See <a href="https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Tiered+Storage+Early+Access+Release+Notes";>Early Access Notes</a> for more details.</p> <p><i>Note: ZooKeeper is marked as deprecated since 3.5.0 release. ZooKeeper is planned to be removed in Apache Kafka 4.0. (Cf <a href="/documentation#zk_depr">ZooKeeper Deprecation</a>)</i><p> <h3>Kafka Broker, Controller, Producer, Consumer and Admin Client</h3> <ul> - <li><b>KIP-405: Kafka Tiered Storage</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-405%3A+Kafka+Tiered+Storage";>KIP-405</a>. It introduces tiered storage feature in Kafka that provides separation of computation and storage in the broker.</li> - <li><b>KIP-797: Accept duplicate listener on port for IPv4/IPv6</b><a href="https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=195726330";>KIP-797</a>. Brokers can be configured with listeners that have same port on different ip stack like ipv4 and ipv6.</li> - <li><b>KIP-863: Reduce CompletedFetch#parseRecord() memory copy</b><a href="https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=225152035";>KIP-863</a>. Reduced CompletedFetch#parseRecord() memory copy by deserializing using byte buffers.</li> - <li><b>KIP-868: Metadata Transactions</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-868+Metadata+Transactions";>KIP-868</a>. This feature is about allowing the controller to generate atomic transactions of records that can exceed the maximum batch size.</li> - <li><b>KIP-902: Upgrade Zookeeper to 3.8.2</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-902%3A+Upgrade+Zookeeper+to+3.8.2";>KIP-902</a>. Zookeeper client upgraded to 3.8.2 version as the current zookeeper dependency version 3.6.3 reached the end of life.</li> - <li><b>KIP-917: Additional custom metadata for remote log segment</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-917%3A+Additional+custom+metadata+for+remote+log+segment";>KIP-917</a>. Custom metedata support for remote log segments.</li> - <li><b>KIP-930: Rename ambiguous Tiered Storage Metrics</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-930%3A+Rename+ambiguous+Tiered+Storage+Metrics";>KIP-930</a>. Renamed ambiguous tiered storage metrics.</li> - <li><b>KIP-937: Improve Message Timestamp Validation</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-937%3A+Improve+Message+Timestamp+Validation";>KIP-937</a>. Improved Producer's record timestamp validation.</li> - <li><b>KIP-938: Add more metrics for measuring KRaft performance</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-938%3A+Add+more+metrics+for+measuring+KRaft+performance";>KIP-938</a>. Added the targeted KRaft performance metrics mentioned in KIP-938 except ForwardingManager metrics.</li> + <li><b>KIP-405: Kafka Tiered Storage: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-405%3A+Kafka+Tiered+Storage";>KIP-405</a>. It introduces tiered storage feature in Kafka that provides separation of computation and storage in the broker.</li> + <li><b>KIP-797: Accept duplicate listener on port for IPv4/IPv6: </b><a href="https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=195726330";>KIP-797</a>. Brokers can be configured with listeners that have same port on different ip stack like ipv4 and ipv6.</li> + <li><b>KIP-863: Reduce CompletedFetch#parseRecord() memory copy: </b><a href="https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=225152035";>KIP-863</a>. Reduced CompletedFetch#parseRecord() memory copy by deserializing using byte buffers.</li> + <li><b>KIP-868: Metadata Transactions: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-868+Metadata+Transactions";>KIP-868</a>. This feature is about allowing the controller to generate atomic transactions of records that can exceed the maximum batch size.</li> + <li><b>KIP-902: Upgrade Zookeeper to 3.8.2: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-902%3A+Upgrade+Zookeeper+to+3.8.2";>KIP-902</a>. Zookeeper client upgraded to 3.8.2 version as the current Zookeeper dependency version 3.6.3 reached the end of life.</li> + <li><b>KIP-917: Additional custom metadata for remote log segment: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-917%3A+Additional+custom+metadata+for+remote+log+segment";>KIP-917</a>. Custom metedata support for remote log segments.</li> + <li><b>KIP-930: Rename ambiguous Tiered Storage Metrics: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-930%3A+Rename+ambiguous+Tiered+Storage+Metrics";>KIP-930</a>. Renamed ambiguous tiered storage metrics.</li> + <li><b>KIP-937: Improve Message Timestamp Validation: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-937%3A+Improve+Message+Timestamp+Validation";>KIP-937</a>. Improved Producer's record timestamp validation.</li> + <li><b>KIP-938: Add more metrics for measuring KRaft performance: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-938%3A+Add+more+metrics+for+measuring+KRaft+performance";>KIP-938</a>. Added the targeted KRaft performance metrics mentioned in KIP-938 except ForwardingManager metrics.</li> </ul> <h3>Kafka Streams</h3> <ul> - <li><b>KIP-923: Add A Grace Period to Stream Table Join</b>: <a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-923%3A+Add+A+Grace+Period+to+Stream+Table+Join";>KIP-923</a>Added a grace period to Stream Table join.</li> - <li><b>KIP-941: Range queries to accept null lower and upper bounds</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-941%3A+Range+queries+to+accept+null+lower+and+upper+bounds";>KIP-941</a> Range queries accept lower and upper bounds as null values.</li> + <li><b>KIP-923: Add A Grace Period to Stream Table Join: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-923%3A+Add+A+Grace+Period+to+Stream+Table+Join";>KIP-923</a>Added a grace period to Stream Table join.</li> + <li><b>KIP-941: Range queries to accept null lower and upper bounds: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-941%3A+Range+queries+to+accept+null+lower+and+upper+bounds";>KIP-941</a> Range queries accept lower and upper bounds as null values.</li> Review Comment: Missing a dot after `KIP-941` ########## blog.html: ########## @@ -39,35 +39,35 @@ <h2 class="bullet"> for details regarding KRaft and JBOD. </p> <p>Support for Delegation Tokens in KRaft (<a href="https://issues.apache.org/jira/browse/KAFKA-15219";>KAFKA-15219</a>) was completed in 3.6, further reducing the gap of features between ZooKeeper-based Kafka clusters and KRaft. Migration of delegation tokens from ZooKeeper to KRaft is also included in 3.6.</p> - <p><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-405%3A+Kafka+Tiered+Storage";>Tiered Storage<a> is an early access feature. It is currently only suitable for testing in non production environments. See <a href="https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Tiered+Storage+Early+Access+Release+Notes";>Early Access Notes</a> for more details.</p> + <p><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-405%3A+Kafka+Tiered+Storage";>Tiered Storage</a> is an early access feature. It is currently only suitable for testing in non production environments. See <a href="https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Tiered+Storage+Early+Access+Release+Notes";>Early Access Notes</a> for more details.</p> <p><i>Note: ZooKeeper is marked as deprecated since 3.5.0 release. ZooKeeper is planned to be removed in Apache Kafka 4.0. (Cf <a href="/documentation#zk_depr">ZooKeeper Deprecation</a>)</i><p> <h3>Kafka Broker, Controller, Producer, Consumer and Admin Client</h3> <ul> - <li><b>KIP-405: Kafka Tiered Storage</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-405%3A+Kafka+Tiered+Storage";>KIP-405</a>. It introduces tiered storage feature in Kafka that provides separation of computation and storage in the broker.</li> - <li><b>KIP-797: Accept duplicate listener on port for IPv4/IPv6</b><a href="https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=195726330";>KIP-797</a>. Brokers can be configured with listeners that have same port on different ip stack like ipv4 and ipv6.</li> - <li><b>KIP-863: Reduce CompletedFetch#parseRecord() memory copy</b><a href="https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=225152035";>KIP-863</a>. Reduced CompletedFetch#parseRecord() memory copy by deserializing using byte buffers.</li> - <li><b>KIP-868: Metadata Transactions</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-868+Metadata+Transactions";>KIP-868</a>. This feature is about allowing the controller to generate atomic transactions of records that can exceed the maximum batch size.</li> - <li><b>KIP-902: Upgrade Zookeeper to 3.8.2</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-902%3A+Upgrade+Zookeeper+to+3.8.2";>KIP-902</a>. Zookeeper client upgraded to 3.8.2 version as the current zookeeper dependency version 3.6.3 reached the end of life.</li> - <li><b>KIP-917: Additional custom metadata for remote log segment</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-917%3A+Additional+custom+metadata+for+remote+log+segment";>KIP-917</a>. Custom metedata support for remote log segments.</li> - <li><b>KIP-930: Rename ambiguous Tiered Storage Metrics</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-930%3A+Rename+ambiguous+Tiered+Storage+Metrics";>KIP-930</a>. Renamed ambiguous tiered storage metrics.</li> - <li><b>KIP-937: Improve Message Timestamp Validation</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-937%3A+Improve+Message+Timestamp+Validation";>KIP-937</a>. Improved Producer's record timestamp validation.</li> - <li><b>KIP-938: Add more metrics for measuring KRaft performance</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-938%3A+Add+more+metrics+for+measuring+KRaft+performance";>KIP-938</a>. Added the targeted KRaft performance metrics mentioned in KIP-938 except ForwardingManager metrics.</li> + <li><b>KIP-405: Kafka Tiered Storage: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-405%3A+Kafka+Tiered+Storage";>KIP-405</a>. It introduces tiered storage feature in Kafka that provides separation of computation and storage in the broker.</li> + <li><b>KIP-797: Accept duplicate listener on port for IPv4/IPv6: </b><a href="https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=195726330";>KIP-797</a>. Brokers can be configured with listeners that have same port on different ip stack like ipv4 and ipv6.</li> + <li><b>KIP-863: Reduce CompletedFetch#parseRecord() memory copy: </b><a href="https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=225152035";>KIP-863</a>. Reduced CompletedFetch#parseRecord() memory copy by deserializing using byte buffers.</li> + <li><b>KIP-868: Metadata Transactions: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-868+Metadata+Transactions";>KIP-868</a>. This feature is about allowing the controller to generate atomic transactions of records that can exceed the maximum batch size.</li> + <li><b>KIP-902: Upgrade Zookeeper to 3.8.2: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-902%3A+Upgrade+Zookeeper+to+3.8.2";>KIP-902</a>. Zookeeper client upgraded to 3.8.2 version as the current Zookeeper dependency version 3.6.3 reached the end of life.</li> + <li><b>KIP-917: Additional custom metadata for remote log segment: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-917%3A+Additional+custom+metadata+for+remote+log+segment";>KIP-917</a>. Custom metedata support for remote log segments.</li> + <li><b>KIP-930: Rename ambiguous Tiered Storage Metrics: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-930%3A+Rename+ambiguous+Tiered+Storage+Metrics";>KIP-930</a>. Renamed ambiguous tiered storage metrics.</li> + <li><b>KIP-937: Improve Message Timestamp Validation: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-937%3A+Improve+Message+Timestamp+Validation";>KIP-937</a>. Improved Producer's record timestamp validation.</li> + <li><b>KIP-938: Add more metrics for measuring KRaft performance: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-938%3A+Add+more+metrics+for+measuring+KRaft+performance";>KIP-938</a>. Added the targeted KRaft performance metrics mentioned in KIP-938 except ForwardingManager metrics.</li> </ul> <h3>Kafka Streams</h3> <ul> - <li><b>KIP-923: Add A Grace Period to Stream Table Join</b>: <a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-923%3A+Add+A+Grace+Period+to+Stream+Table+Join";>KIP-923</a>Added a grace period to Stream Table join.</li> - <li><b>KIP-941: Range queries to accept null lower and upper bounds</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-941%3A+Range+queries+to+accept+null+lower+and+upper+bounds";>KIP-941</a> Range queries accept lower and upper bounds as null values.</li> + <li><b>KIP-923: Add A Grace Period to Stream Table Join: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-923%3A+Add+A+Grace+Period+to+Stream+Table+Join";>KIP-923</a>Added a grace period to Stream Table join.</li> + <li><b>KIP-941: Range queries to accept null lower and upper bounds: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-941%3A+Range+queries+to+accept+null+lower+and+upper+bounds";>KIP-941</a> Range queries accept lower and upper bounds as null values.</li> </ul> <h3>Kafka Connect</h3> <ul> - <li><b>KIP-793: Allow sink connectors to be used with topic-mutating SMTs</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-793%3A+Allow+sink+connectors+to+be+used+with+topic-mutating+SMTs";>KIP-793</a>. It supports topic-mutating SMTs for async sink connectors.</li> - <li><b>KIP-875: First-class offsets support in Kafka Connect</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-875%3A+First-class+offsets+support+in+Kafka+Connect";>KIP-875</a>. Kafka Connect supports offset reset.</li> - <li><b>KIP-898: Modernize Connect plugin discovery</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-898%3A+Modernize+Connect+plugin+discovery";>KIP-898</a>.The worker will read plugin classes from ServiceLoader manifests and module info during startup.</li> + <li><b>KIP-793: Allow sink connectors to be used with topic-mutating SMTs: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-793%3A+Allow+sink+connectors+to+be+used+with+topic-mutating+SMTs";>KIP-793</a>. It supports topic-mutating SMTs for async sink connectors.</li> + <li><b>KIP-875: First-class offsets support in Kafka Connect: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-875%3A+First-class+offsets+support+in+Kafka+Connect";>KIP-875</a>. Kafka Connect supports offset reset.</li> + <li><b>KIP-898: Modernize Connect plugin discovery: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-898%3A+Modernize+Connect+plugin+discovery";>KIP-898</a>.The worker will read plugin classes from ServiceLoader manifests and module info during startup.</li> Review Comment: Missing a space before `The` ########## blog.html: ########## @@ -39,35 +39,35 @@ <h2 class="bullet"> for details regarding KRaft and JBOD. </p> <p>Support for Delegation Tokens in KRaft (<a href="https://issues.apache.org/jira/browse/KAFKA-15219";>KAFKA-15219</a>) was completed in 3.6, further reducing the gap of features between ZooKeeper-based Kafka clusters and KRaft. Migration of delegation tokens from ZooKeeper to KRaft is also included in 3.6.</p> - <p><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-405%3A+Kafka+Tiered+Storage";>Tiered Storage<a> is an early access feature. It is currently only suitable for testing in non production environments. See <a href="https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Tiered+Storage+Early+Access+Release+Notes";>Early Access Notes</a> for more details.</p> + <p><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-405%3A+Kafka+Tiered+Storage";>Tiered Storage</a> is an early access feature. It is currently only suitable for testing in non production environments. See <a href="https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Tiered+Storage+Early+Access+Release+Notes";>Early Access Notes</a> for more details.</p> <p><i>Note: ZooKeeper is marked as deprecated since 3.5.0 release. ZooKeeper is planned to be removed in Apache Kafka 4.0. (Cf <a href="/documentation#zk_depr">ZooKeeper Deprecation</a>)</i><p> <h3>Kafka Broker, Controller, Producer, Consumer and Admin Client</h3> <ul> - <li><b>KIP-405: Kafka Tiered Storage</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-405%3A+Kafka+Tiered+Storage";>KIP-405</a>. It introduces tiered storage feature in Kafka that provides separation of computation and storage in the broker.</li> - <li><b>KIP-797: Accept duplicate listener on port for IPv4/IPv6</b><a href="https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=195726330";>KIP-797</a>. Brokers can be configured with listeners that have same port on different ip stack like ipv4 and ipv6.</li> - <li><b>KIP-863: Reduce CompletedFetch#parseRecord() memory copy</b><a href="https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=225152035";>KIP-863</a>. Reduced CompletedFetch#parseRecord() memory copy by deserializing using byte buffers.</li> - <li><b>KIP-868: Metadata Transactions</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-868+Metadata+Transactions";>KIP-868</a>. This feature is about allowing the controller to generate atomic transactions of records that can exceed the maximum batch size.</li> - <li><b>KIP-902: Upgrade Zookeeper to 3.8.2</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-902%3A+Upgrade+Zookeeper+to+3.8.2";>KIP-902</a>. Zookeeper client upgraded to 3.8.2 version as the current zookeeper dependency version 3.6.3 reached the end of life.</li> - <li><b>KIP-917: Additional custom metadata for remote log segment</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-917%3A+Additional+custom+metadata+for+remote+log+segment";>KIP-917</a>. Custom metedata support for remote log segments.</li> - <li><b>KIP-930: Rename ambiguous Tiered Storage Metrics</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-930%3A+Rename+ambiguous+Tiered+Storage+Metrics";>KIP-930</a>. Renamed ambiguous tiered storage metrics.</li> - <li><b>KIP-937: Improve Message Timestamp Validation</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-937%3A+Improve+Message+Timestamp+Validation";>KIP-937</a>. Improved Producer's record timestamp validation.</li> - <li><b>KIP-938: Add more metrics for measuring KRaft performance</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-938%3A+Add+more+metrics+for+measuring+KRaft+performance";>KIP-938</a>. Added the targeted KRaft performance metrics mentioned in KIP-938 except ForwardingManager metrics.</li> + <li><b>KIP-405: Kafka Tiered Storage: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-405%3A+Kafka+Tiered+Storage";>KIP-405</a>. It introduces tiered storage feature in Kafka that provides separation of computation and storage in the broker.</li> + <li><b>KIP-797: Accept duplicate listener on port for IPv4/IPv6: </b><a href="https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=195726330";>KIP-797</a>. Brokers can be configured with listeners that have same port on different ip stack like ipv4 and ipv6.</li> + <li><b>KIP-863: Reduce CompletedFetch#parseRecord() memory copy: </b><a href="https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=225152035";>KIP-863</a>. Reduced CompletedFetch#parseRecord() memory copy by deserializing using byte buffers.</li> + <li><b>KIP-868: Metadata Transactions: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-868+Metadata+Transactions";>KIP-868</a>. This feature is about allowing the controller to generate atomic transactions of records that can exceed the maximum batch size.</li> + <li><b>KIP-902: Upgrade Zookeeper to 3.8.2: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-902%3A+Upgrade+Zookeeper+to+3.8.2";>KIP-902</a>. Zookeeper client upgraded to 3.8.2 version as the current Zookeeper dependency version 3.6.3 reached the end of life.</li> + <li><b>KIP-917: Additional custom metadata for remote log segment: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-917%3A+Additional+custom+metadata+for+remote+log+segment";>KIP-917</a>. Custom metedata support for remote log segments.</li> + <li><b>KIP-930: Rename ambiguous Tiered Storage Metrics: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-930%3A+Rename+ambiguous+Tiered+Storage+Metrics";>KIP-930</a>. Renamed ambiguous tiered storage metrics.</li> Review Comment: What about: `This improved the naming of Tiered Storage metrics to make them more user friendly.`? ########## blog.html: ########## @@ -39,35 +39,35 @@ <h2 class="bullet"> for details regarding KRaft and JBOD. </p> <p>Support for Delegation Tokens in KRaft (<a href="https://issues.apache.org/jira/browse/KAFKA-15219";>KAFKA-15219</a>) was completed in 3.6, further reducing the gap of features between ZooKeeper-based Kafka clusters and KRaft. Migration of delegation tokens from ZooKeeper to KRaft is also included in 3.6.</p> - <p><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-405%3A+Kafka+Tiered+Storage";>Tiered Storage<a> is an early access feature. It is currently only suitable for testing in non production environments. See <a href="https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Tiered+Storage+Early+Access+Release+Notes";>Early Access Notes</a> for more details.</p> + <p><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-405%3A+Kafka+Tiered+Storage";>Tiered Storage</a> is an early access feature. It is currently only suitable for testing in non production environments. See <a href="https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Tiered+Storage+Early+Access+Release+Notes";>Early Access Notes</a> for more details.</p> <p><i>Note: ZooKeeper is marked as deprecated since 3.5.0 release. ZooKeeper is planned to be removed in Apache Kafka 4.0. (Cf <a href="/documentation#zk_depr">ZooKeeper Deprecation</a>)</i><p> <h3>Kafka Broker, Controller, Producer, Consumer and Admin Client</h3> <ul> - <li><b>KIP-405: Kafka Tiered Storage</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-405%3A+Kafka+Tiered+Storage";>KIP-405</a>. It introduces tiered storage feature in Kafka that provides separation of computation and storage in the broker.</li> - <li><b>KIP-797: Accept duplicate listener on port for IPv4/IPv6</b><a href="https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=195726330";>KIP-797</a>. Brokers can be configured with listeners that have same port on different ip stack like ipv4 and ipv6.</li> - <li><b>KIP-863: Reduce CompletedFetch#parseRecord() memory copy</b><a href="https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=225152035";>KIP-863</a>. Reduced CompletedFetch#parseRecord() memory copy by deserializing using byte buffers.</li> - <li><b>KIP-868: Metadata Transactions</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-868+Metadata+Transactions";>KIP-868</a>. This feature is about allowing the controller to generate atomic transactions of records that can exceed the maximum batch size.</li> - <li><b>KIP-902: Upgrade Zookeeper to 3.8.2</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-902%3A+Upgrade+Zookeeper+to+3.8.2";>KIP-902</a>. Zookeeper client upgraded to 3.8.2 version as the current zookeeper dependency version 3.6.3 reached the end of life.</li> - <li><b>KIP-917: Additional custom metadata for remote log segment</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-917%3A+Additional+custom+metadata+for+remote+log+segment";>KIP-917</a>. Custom metedata support for remote log segments.</li> - <li><b>KIP-930: Rename ambiguous Tiered Storage Metrics</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-930%3A+Rename+ambiguous+Tiered+Storage+Metrics";>KIP-930</a>. Renamed ambiguous tiered storage metrics.</li> - <li><b>KIP-937: Improve Message Timestamp Validation</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-937%3A+Improve+Message+Timestamp+Validation";>KIP-937</a>. Improved Producer's record timestamp validation.</li> - <li><b>KIP-938: Add more metrics for measuring KRaft performance</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-938%3A+Add+more+metrics+for+measuring+KRaft+performance";>KIP-938</a>. Added the targeted KRaft performance metrics mentioned in KIP-938 except ForwardingManager metrics.</li> + <li><b>KIP-405: Kafka Tiered Storage: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-405%3A+Kafka+Tiered+Storage";>KIP-405</a>. It introduces tiered storage feature in Kafka that provides separation of computation and storage in the broker.</li> + <li><b>KIP-797: Accept duplicate listener on port for IPv4/IPv6: </b><a href="https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=195726330";>KIP-797</a>. Brokers can be configured with listeners that have same port on different ip stack like ipv4 and ipv6.</li> + <li><b>KIP-863: Reduce CompletedFetch#parseRecord() memory copy: </b><a href="https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=225152035";>KIP-863</a>. Reduced CompletedFetch#parseRecord() memory copy by deserializing using byte buffers.</li> + <li><b>KIP-868: Metadata Transactions: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-868+Metadata+Transactions";>KIP-868</a>. This feature is about allowing the controller to generate atomic transactions of records that can exceed the maximum batch size.</li> + <li><b>KIP-902: Upgrade Zookeeper to 3.8.2: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-902%3A+Upgrade+Zookeeper+to+3.8.2";>KIP-902</a>. Zookeeper client upgraded to 3.8.2 version as the current Zookeeper dependency version 3.6.3 reached the end of life.</li> + <li><b>KIP-917: Additional custom metadata for remote log segment: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-917%3A+Additional+custom+metadata+for+remote+log+segment";>KIP-917</a>. Custom metedata support for remote log segments.</li> + <li><b>KIP-930: Rename ambiguous Tiered Storage Metrics: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-930%3A+Rename+ambiguous+Tiered+Storage+Metrics";>KIP-930</a>. Renamed ambiguous tiered storage metrics.</li> + <li><b>KIP-937: Improve Message Timestamp Validation: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-937%3A+Improve+Message+Timestamp+Validation";>KIP-937</a>. Improved Producer's record timestamp validation.</li> + <li><b>KIP-938: Add more metrics for measuring KRaft performance: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-938%3A+Add+more+metrics+for+measuring+KRaft+performance";>KIP-938</a>. Added the targeted KRaft performance metrics mentioned in KIP-938 except ForwardingManager metrics.</li> </ul> <h3>Kafka Streams</h3> <ul> - <li><b>KIP-923: Add A Grace Period to Stream Table Join</b>: <a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-923%3A+Add+A+Grace+Period+to+Stream+Table+Join";>KIP-923</a>Added a grace period to Stream Table join.</li> - <li><b>KIP-941: Range queries to accept null lower and upper bounds</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-941%3A+Range+queries+to+accept+null+lower+and+upper+bounds";>KIP-941</a> Range queries accept lower and upper bounds as null values.</li> + <li><b>KIP-923: Add A Grace Period to Stream Table Join: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-923%3A+Add+A+Grace+Period+to+Stream+Table+Join";>KIP-923</a>Added a grace period to Stream Table join.</li> Review Comment: What about `This adds a grace period buffer to the stream side of Stream Table joins to improve processing of out of order data`? ########## blog.html: ########## @@ -39,35 +39,35 @@ <h2 class="bullet"> for details regarding KRaft and JBOD. </p> <p>Support for Delegation Tokens in KRaft (<a href="https://issues.apache.org/jira/browse/KAFKA-15219";>KAFKA-15219</a>) was completed in 3.6, further reducing the gap of features between ZooKeeper-based Kafka clusters and KRaft. Migration of delegation tokens from ZooKeeper to KRaft is also included in 3.6.</p> - <p><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-405%3A+Kafka+Tiered+Storage";>Tiered Storage<a> is an early access feature. It is currently only suitable for testing in non production environments. See <a href="https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Tiered+Storage+Early+Access+Release+Notes";>Early Access Notes</a> for more details.</p> + <p><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-405%3A+Kafka+Tiered+Storage";>Tiered Storage</a> is an early access feature. It is currently only suitable for testing in non production environments. See <a href="https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Tiered+Storage+Early+Access+Release+Notes";>Early Access Notes</a> for more details.</p> <p><i>Note: ZooKeeper is marked as deprecated since 3.5.0 release. ZooKeeper is planned to be removed in Apache Kafka 4.0. (Cf <a href="/documentation#zk_depr">ZooKeeper Deprecation</a>)</i><p> <h3>Kafka Broker, Controller, Producer, Consumer and Admin Client</h3> <ul> - <li><b>KIP-405: Kafka Tiered Storage</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-405%3A+Kafka+Tiered+Storage";>KIP-405</a>. It introduces tiered storage feature in Kafka that provides separation of computation and storage in the broker.</li> - <li><b>KIP-797: Accept duplicate listener on port for IPv4/IPv6</b><a href="https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=195726330";>KIP-797</a>. Brokers can be configured with listeners that have same port on different ip stack like ipv4 and ipv6.</li> - <li><b>KIP-863: Reduce CompletedFetch#parseRecord() memory copy</b><a href="https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=225152035";>KIP-863</a>. Reduced CompletedFetch#parseRecord() memory copy by deserializing using byte buffers.</li> - <li><b>KIP-868: Metadata Transactions</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-868+Metadata+Transactions";>KIP-868</a>. This feature is about allowing the controller to generate atomic transactions of records that can exceed the maximum batch size.</li> - <li><b>KIP-902: Upgrade Zookeeper to 3.8.2</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-902%3A+Upgrade+Zookeeper+to+3.8.2";>KIP-902</a>. Zookeeper client upgraded to 3.8.2 version as the current zookeeper dependency version 3.6.3 reached the end of life.</li> - <li><b>KIP-917: Additional custom metadata for remote log segment</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-917%3A+Additional+custom+metadata+for+remote+log+segment";>KIP-917</a>. Custom metedata support for remote log segments.</li> - <li><b>KIP-930: Rename ambiguous Tiered Storage Metrics</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-930%3A+Rename+ambiguous+Tiered+Storage+Metrics";>KIP-930</a>. Renamed ambiguous tiered storage metrics.</li> - <li><b>KIP-937: Improve Message Timestamp Validation</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-937%3A+Improve+Message+Timestamp+Validation";>KIP-937</a>. Improved Producer's record timestamp validation.</li> - <li><b>KIP-938: Add more metrics for measuring KRaft performance</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-938%3A+Add+more+metrics+for+measuring+KRaft+performance";>KIP-938</a>. Added the targeted KRaft performance metrics mentioned in KIP-938 except ForwardingManager metrics.</li> + <li><b>KIP-405: Kafka Tiered Storage: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-405%3A+Kafka+Tiered+Storage";>KIP-405</a>. It introduces tiered storage feature in Kafka that provides separation of computation and storage in the broker.</li> + <li><b>KIP-797: Accept duplicate listener on port for IPv4/IPv6: </b><a href="https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=195726330";>KIP-797</a>. Brokers can be configured with listeners that have same port on different ip stack like ipv4 and ipv6.</li> + <li><b>KIP-863: Reduce CompletedFetch#parseRecord() memory copy: </b><a href="https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=225152035";>KIP-863</a>. Reduced CompletedFetch#parseRecord() memory copy by deserializing using byte buffers.</li> + <li><b>KIP-868: Metadata Transactions: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-868+Metadata+Transactions";>KIP-868</a>. This feature is about allowing the controller to generate atomic transactions of records that can exceed the maximum batch size.</li> + <li><b>KIP-902: Upgrade Zookeeper to 3.8.2: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-902%3A+Upgrade+Zookeeper+to+3.8.2";>KIP-902</a>. Zookeeper client upgraded to 3.8.2 version as the current Zookeeper dependency version 3.6.3 reached the end of life.</li> + <li><b>KIP-917: Additional custom metadata for remote log segment: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-917%3A+Additional+custom+metadata+for+remote+log+segment";>KIP-917</a>. Custom metedata support for remote log segments.</li> + <li><b>KIP-930: Rename ambiguous Tiered Storage Metrics: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-930%3A+Rename+ambiguous+Tiered+Storage+Metrics";>KIP-930</a>. Renamed ambiguous tiered storage metrics.</li> + <li><b>KIP-937: Improve Message Timestamp Validation: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-937%3A+Improve+Message+Timestamp+Validation";>KIP-937</a>. Improved Producer's record timestamp validation.</li> Review Comment: What about: `This adds 2 new configurations to brokers, <code>log.message.timestamp.before.max.ms</code> and <code>log.message.timestamp.after.max.ms</code> to allow broker to validate timestamp of records and reject them if their timestamps are outside of the configured range.`? ########## blog.html: ########## @@ -39,35 +39,35 @@ <h2 class="bullet"> for details regarding KRaft and JBOD. </p> <p>Support for Delegation Tokens in KRaft (<a href="https://issues.apache.org/jira/browse/KAFKA-15219";>KAFKA-15219</a>) was completed in 3.6, further reducing the gap of features between ZooKeeper-based Kafka clusters and KRaft. Migration of delegation tokens from ZooKeeper to KRaft is also included in 3.6.</p> - <p><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-405%3A+Kafka+Tiered+Storage";>Tiered Storage<a> is an early access feature. It is currently only suitable for testing in non production environments. See <a href="https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Tiered+Storage+Early+Access+Release+Notes";>Early Access Notes</a> for more details.</p> + <p><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-405%3A+Kafka+Tiered+Storage";>Tiered Storage</a> is an early access feature. It is currently only suitable for testing in non production environments. See <a href="https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Tiered+Storage+Early+Access+Release+Notes";>Early Access Notes</a> for more details.</p> <p><i>Note: ZooKeeper is marked as deprecated since 3.5.0 release. ZooKeeper is planned to be removed in Apache Kafka 4.0. (Cf <a href="/documentation#zk_depr">ZooKeeper Deprecation</a>)</i><p> <h3>Kafka Broker, Controller, Producer, Consumer and Admin Client</h3> <ul> - <li><b>KIP-405: Kafka Tiered Storage</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-405%3A+Kafka+Tiered+Storage";>KIP-405</a>. It introduces tiered storage feature in Kafka that provides separation of computation and storage in the broker.</li> - <li><b>KIP-797: Accept duplicate listener on port for IPv4/IPv6</b><a href="https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=195726330";>KIP-797</a>. Brokers can be configured with listeners that have same port on different ip stack like ipv4 and ipv6.</li> - <li><b>KIP-863: Reduce CompletedFetch#parseRecord() memory copy</b><a href="https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=225152035";>KIP-863</a>. Reduced CompletedFetch#parseRecord() memory copy by deserializing using byte buffers.</li> - <li><b>KIP-868: Metadata Transactions</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-868+Metadata+Transactions";>KIP-868</a>. This feature is about allowing the controller to generate atomic transactions of records that can exceed the maximum batch size.</li> - <li><b>KIP-902: Upgrade Zookeeper to 3.8.2</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-902%3A+Upgrade+Zookeeper+to+3.8.2";>KIP-902</a>. Zookeeper client upgraded to 3.8.2 version as the current zookeeper dependency version 3.6.3 reached the end of life.</li> - <li><b>KIP-917: Additional custom metadata for remote log segment</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-917%3A+Additional+custom+metadata+for+remote+log+segment";>KIP-917</a>. Custom metedata support for remote log segments.</li> - <li><b>KIP-930: Rename ambiguous Tiered Storage Metrics</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-930%3A+Rename+ambiguous+Tiered+Storage+Metrics";>KIP-930</a>. Renamed ambiguous tiered storage metrics.</li> - <li><b>KIP-937: Improve Message Timestamp Validation</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-937%3A+Improve+Message+Timestamp+Validation";>KIP-937</a>. Improved Producer's record timestamp validation.</li> - <li><b>KIP-938: Add more metrics for measuring KRaft performance</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-938%3A+Add+more+metrics+for+measuring+KRaft+performance";>KIP-938</a>. Added the targeted KRaft performance metrics mentioned in KIP-938 except ForwardingManager metrics.</li> + <li><b>KIP-405: Kafka Tiered Storage: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-405%3A+Kafka+Tiered+Storage";>KIP-405</a>. It introduces tiered storage feature in Kafka that provides separation of computation and storage in the broker.</li> + <li><b>KIP-797: Accept duplicate listener on port for IPv4/IPv6: </b><a href="https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=195726330";>KIP-797</a>. Brokers can be configured with listeners that have same port on different ip stack like ipv4 and ipv6.</li> + <li><b>KIP-863: Reduce CompletedFetch#parseRecord() memory copy: </b><a href="https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=225152035";>KIP-863</a>. Reduced CompletedFetch#parseRecord() memory copy by deserializing using byte buffers.</li> + <li><b>KIP-868: Metadata Transactions: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-868+Metadata+Transactions";>KIP-868</a>. This feature is about allowing the controller to generate atomic transactions of records that can exceed the maximum batch size.</li> + <li><b>KIP-902: Upgrade Zookeeper to 3.8.2: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-902%3A+Upgrade+Zookeeper+to+3.8.2";>KIP-902</a>. Zookeeper client upgraded to 3.8.2 version as the current Zookeeper dependency version 3.6.3 reached the end of life.</li> + <li><b>KIP-917: Additional custom metadata for remote log segment: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-917%3A+Additional+custom+metadata+for+remote+log+segment";>KIP-917</a>. Custom metedata support for remote log segments.</li> + <li><b>KIP-930: Rename ambiguous Tiered Storage Metrics: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-930%3A+Rename+ambiguous+Tiered+Storage+Metrics";>KIP-930</a>. Renamed ambiguous tiered storage metrics.</li> + <li><b>KIP-937: Improve Message Timestamp Validation: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-937%3A+Improve+Message+Timestamp+Validation";>KIP-937</a>. Improved Producer's record timestamp validation.</li> + <li><b>KIP-938: Add more metrics for measuring KRaft performance: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-938%3A+Add+more+metrics+for+measuring+KRaft+performance";>KIP-938</a>. Added the targeted KRaft performance metrics mentioned in KIP-938 except ForwardingManager metrics.</li> </ul> <h3>Kafka Streams</h3> <ul> - <li><b>KIP-923: Add A Grace Period to Stream Table Join</b>: <a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-923%3A+Add+A+Grace+Period+to+Stream+Table+Join";>KIP-923</a>Added a grace period to Stream Table join.</li> - <li><b>KIP-941: Range queries to accept null lower and upper bounds</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-941%3A+Range+queries+to+accept+null+lower+and+upper+bounds";>KIP-941</a> Range queries accept lower and upper bounds as null values.</li> + <li><b>KIP-923: Add A Grace Period to Stream Table Join: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-923%3A+Add+A+Grace+Period+to+Stream+Table+Join";>KIP-923</a>Added a grace period to Stream Table join.</li> + <li><b>KIP-941: Range queries to accept null lower and upper bounds: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-941%3A+Range+queries+to+accept+null+lower+and+upper+bounds";>KIP-941</a> Range queries accept lower and upper bounds as null values.</li> </ul> <h3>Kafka Connect</h3> <ul> - <li><b>KIP-793: Allow sink connectors to be used with topic-mutating SMTs</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-793%3A+Allow+sink+connectors+to+be+used+with+topic-mutating+SMTs";>KIP-793</a>. It supports topic-mutating SMTs for async sink connectors.</li> - <li><b>KIP-875: First-class offsets support in Kafka Connect</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-875%3A+First-class+offsets+support+in+Kafka+Connect";>KIP-875</a>. Kafka Connect supports offset reset.</li> - <li><b>KIP-898: Modernize Connect plugin discovery</b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-898%3A+Modernize+Connect+plugin+discovery";>KIP-898</a>.The worker will read plugin classes from ServiceLoader manifests and module info during startup.</li> + <li><b>KIP-793: Allow sink connectors to be used with topic-mutating SMTs: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-793%3A+Allow+sink+connectors+to+be+used+with+topic-mutating+SMTs";>KIP-793</a>. It supports topic-mutating SMTs for async sink connectors.</li> + <li><b>KIP-875: First-class offsets support in Kafka Connect: </b><a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-875%3A+First-class+offsets+support+in+Kafka+Connect";>KIP-875</a>. Kafka Connect supports offset reset.</li> Review Comment: What about: `This add new endpoints to the Connect REST API to retrieve and reset the offsets of connectors.`? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: dev-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org