Versions Compared

Old Version 2

changes.mady.by.user Jeremy DeGroot

Saved on

compared with

New Version 3

changes.mady.by.user Jeremy DeGroot

Saved on

Key

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

...

KafkaSourceBuilder will get a new method setRackId() that will take a callback as an argument. Setting this value will result in the value of the `clientclient.rack` rack property for the Kafka client on each Task Manager. Note that to see any behavior change or benefit from this setting, the Kafka brokers the client is connecting to must be configured to assign replicas with the RackAwareReplicaSelector and have their own broker rack IDs set correspondingly to the client rack IDs. 

...