...
Code Block | ||
---|---|---|
| ||
public static final String RACK_ID_CONFIG = "rack.id"; private static final String RACK_ID_DOC = "An identifier for the rack of an instance of Kafka Streams. " + "When set, the default implementation of org.apache.kafka.streams.StandbyTaskDistributorRackAwareStandbyTaskAssignor of the Kafka Streams " + "will try to distribute standby tasks in different rack compared to corresponding active task."; public static final String RACK_STANDBY_TASK_ASSIGNOR_CLASS_CONFIG = "rack.standby.task.assignor"; public static final String RACK_STANDBY_TASK_ASSIGNOR_CLASS_DOC = "Class that implements RackAwareStandbyTaskAssignor interface, " + "that is used when deciding on which racks standby tasks can be created."; |
...