You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by lu...@apache.org on 2024/06/14 11:21:48 UTC
(kafka) branch 3_8_upgrade_guide created (now 9e91e27a04b)
This is an automated email from the ASF dual-hosted git repository.
lucasbru pushed a change to branch 3_8_upgrade_guide
in repository https://gitbox.apache.org/repos/asf/kafka.git
at 9e91e27a04b updates
This branch includes the following new commits:
new 9e91e27a04b updates
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
(kafka) 01/01: updates
Posted by lu...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
lucasbru pushed a commit to branch 3_8_upgrade_guide
in repository https://gitbox.apache.org/repos/asf/kafka.git
commit 9e91e27a04b1c60da59f2cf25a63d3ff9c37c7f4
Author: Lucas Brutschy <lb...@confluent.io>
AuthorDate: Fri Jun 14 13:17:38 2024 +0200
updates
---
docs/streams/upgrade-guide.html | 9 +++++++--
1 file changed, 7 insertions(+), 2 deletions(-)
diff --git a/docs/streams/upgrade-guide.html b/docs/streams/upgrade-guide.html
index a13b75dfbbf..dac6698e1cb 100644
--- a/docs/streams/upgrade-guide.html
+++ b/docs/streams/upgrade-guide.html
@@ -146,8 +146,13 @@
<code>HighAvailabilityTaskAssignor</code>. If no custom task assignor is configured, the default task assignor
<code>HighAvailabilityTaskAssignor</code> is used.
- This change also removes the internal config <code>internal.task.assignor.class</code> that was used for the same
- purpose. If you were using this config, you should switch to using <code>task.assignor.class</code> instead.
+ If you were using the <code>internal.task.assignor.class</code> config, you should switch to using the new
+ <code>task.assignor.class</code> config instead, as the internal config will be removed in a future release.
+ If you were previously plugging in the <code>StickyTaskAssignor</code> via the legacy
+ <code>internal.task.assignor.class</code> config, you will need to make sure that you are importing
+ version of the <code>org.apache.kafka.streams.processor.assignment.StickTaskAssignor</code> when you switch
+ over to the new <code>task.assignor.class</code> config, which is a version of the <code>StickyTaskAssignor</code>
+ that implements the new public <code>TaskAssignor</code> interface.
For more details, see the public interface section of
<a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-924%3A+customizable+task+assignment+for+Streams">KIP-924</a>.