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 <lbruts...@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>.
