Hi Jeremy, Thanks for the proposal. I'm curious if this feature can adapt to the current kafka-client version in the connector. The rack awareness feature requires a version>=3.2.0 to use, while the kafka-client version of Kafka connector is 2.8.1. Will we upgrade the Kafka-client version first?
Best, Yanfei Jeremy DeGroot <jeremy.degr...@gmail.com> 于2022年11月11日周五 05:35写道： > Kafak has a rack awareness feature that allows brokers and consumers to > communicate about the rack (or AWS Availability Zone) they're located in. > Reading from a local broker can save money in bandwidth and improve latency > for your consumers. > > This improvement proposes that a Kafka Consumer could be configured with a > callback that could be run when it's being configured on the task manager, > that will set the appropriate value at runtime if a value is provided. > > More detail about this proposal can be found at > > https://cwiki.apache.org/confluence/display/FLINK/FLIP-268%3A+Kafka+Rack+Awareness > > > More information about the Kafka rack awareness feature is at > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-708%3A+Rack+awareness+for+Kafka+Streams > > > Best, > > Jeremy >
