Versions Compared

Old Version 25

changes.mady.by.user Levani Kokhreidze

Saved on

compared with

New Version 26

changes.mady.by.user Levani Kokhreidze

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Code Block
languageyml
public static final String TASK_ASSIGNMENT_RACK_AWARENESS_CONFIG = "task.assignment.rack.awareness";
public static final String TASK_ASSIGNMENT_RACK_AWARENESS_DOC = "List of client tag keys used to distribute standby replicas across Kafka Streams instances." +                                                                
                                                                " When configured, Kafka Streams will make a best effort to distribute" +
                    											" the standby tasks over each client tag dimension.";


Example configuration:

Code Block
# Kafka Streams Client 1
client.tag.zone: eu-central-1a
client.tag.cluster: k8s-cluster1
task.assignment.rack.awareness: zone,cluster

# Kafka Streams Client 2
client.tag.zone: eu-central-1b
client.tag.cluster: k8s-cluster1
task.assignment.rack.awareness: zone,cluster

# Kafka Streams Client 3
client.tag.zone: eu-central-1a
client.tag.cluster: k8s-cluster2
task.assignment.rack.awareness: zone,cluster

# Kafka Streams Client 4
client.tag.zone: eu-central-1b
client.tag.cluster: k8s-cluster2
task.assignment.rack.awareness: zone,cluster


When client.tag.* dimensions are configured, Kafka Streams will read this information from the configuration and encode it into SubscriptionInfoData as key-value pairs.

...