Skip to content

Conversation

@mimaison
Copy link
Member

@mimaison mimaison commented Aug 8, 2025

No description provided.

For a full list of changes, be sure to check the <a href="https://download.apache.org/dist/kafka/4.1.0/RELEASE_NOTES.html">release notes</a>.
</p>
<p>
Queues for Kafka (<a href="https://cwiki.apache.org/confluence/x/4hA0Dw">KIP-932</a>) is now in preview. It's still not ready for

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

It graduated out of "Early Access" and into "Preview" now? IMO worth calling out the progression. I don't think we have both terms clearly defined in meaning anywhere?

Copy link
Member Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I left it out fuzzy as we never voted KIP-1081, or an alternative, so we don't really have an official naming policy.

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I think this ends up confusing more for people who track it. Personally, I remember it being not-ready the previous release - and now we say it's not ready again. I had to go back and explicitly confirm it was "early access" and now it's "preview".

Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I'm trying to follow a similar progression as KIP-1081 without having that KIP adopted. The words here are fine with me.

blog.html Outdated
<li>
<a href="https://cwiki.apache.org/confluence/x/4gm9F">KIP-1152: Add transactional ID pattern filter to ListTransactions API</a>
<br>
When listing transactions you can now provide a pattern to filter based on the transactional ID. In environments with many transactional IDs, this avoid

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Suggested change
When listing transactions you can now provide a pattern to filter based on the transactional ID. In environments with many transactional IDs, this avoid
When listing transactions you can now provide a pattern to filter based on the transactional ID. In environments with many transactional IDs, this avoids

Copy link
Member Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Fixed, thanks

blog.html Outdated
<li>
<a href="https://cwiki.apache.org/confluence/x/JQstEw">KIP-1092: Extend Consumer#close with an option to leave the group or not</a>
<br>
This adds a new <code>Consumer.close(CloseOptions)</code> method which let's define if the consumer should explicitly leave its group when

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Suggested change
This adds a new <code>Consumer.close(CloseOptions)</code> method which let's define if the consumer should explicitly leave its group when
This adds a new <code>Consumer.close(CloseOptions)</code> method which lets us define if the consumer should explicitly leave its group when

nit: I think "lets us" might read a bit more smoothly here?

Copy link
Member Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Yes that's a typo, fixed, thanks

blog.html Outdated
<li>
<a href="https://cwiki.apache.org/confluence/x/LorREw">KIP-1118: Add Deadlock Protection on Producer Network Thread</a>
<br>
From 4.1, if <code>KafkaProducer.flush()</code> is called from the <code>KafkaProducer.send()</code> callback, and exception is raised. Previously this

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Suggested change
From 4.1, if <code>KafkaProducer.flush()</code> is called from the <code>KafkaProducer.send()</code> callback, and exception is raised. Previously this
From 4.1, if <code>KafkaProducer.flush()</code> is called from the <code>KafkaProducer.send()</code> callback, then an exception is raised. Previously this

Copy link
Member Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Thanks, fixed

blog.html Outdated
<li>
<a href="https://cwiki.apache.org/confluence/x/uIxEF">KIP-1139: Add support for OAuth jwt-bearer grant type</a>
<br>
In addition of the client_credentials grant type, Kafka now supports the jwt-bearer grant type for OAuth. This grant type avoids putting secrets in clear

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Suggested change
In addition of the client_credentials grant type, Kafka now supports the jwt-bearer grant type for OAuth. This grant type avoids putting secrets in clear
In addition to the client_credentials grant type, Kafka now supports the jwt-bearer grant type for OAuth. This grant type avoids putting secrets in clear

Copy link
Member Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Thanks, fixed

blog.html Outdated
<a href="https://cwiki.apache.org/confluence/x/8ItyEg">KIP-1050: Consistent error handling for Transactions</a>
<br>
This KIP updates the error handling logic and documentation of all the transaction APIs to make it simpler to build robust applications and build
third party Kafka clients that behave the same way as the Java client.
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

nit: third-party

blog.html Outdated
<li>
<a href="https://cwiki.apache.org/confluence/x/JQstEw">KIP-1092: Extend Consumer#close with an option to leave the group or not</a>
<br>
This adds a new <code>Consumer.close(CloseOptions)</code> method which lets define if the consumer should explicitly leave its group when
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Maybe "lets define if" should be "indicates whether"

blog.html Outdated
<a href="https://cwiki.apache.org/confluence/x/LwqWF">KIP-1143: Deprecated Optional&lt;String&gt; and return String from public Endpoint#listenerName</a>
<br>
This is a cleanup in the <code>Endpoint</code> class. The existing <code>listenerName()</code> method which returns <code>Optional&lt;String&gt;</code> is now
deprecated and users should now transition to the new <code>listenerName()</code> method which returns <code>String</code>.
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

nit: remove the second "now" in this sentence.

blog.html Outdated
<li>
<a href="https://cwiki.apache.org/confluence/x/lY3GDQ">KIP-877: Mechanism for plugins and connectors to register metrics</a>
<br>
All worker and connector plugins can now register their own metrics. For Connectors and tasks this is done via their context. Other plugins
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

nit: "connectors" (lower case)

@mimaison mimaison merged commit 7021dd2 into apache:asf-site Sep 4, 2025
@mimaison mimaison deleted the 41-blog branch September 4, 2025 09:47
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

5 participants