Re: [DISCUSS] FLIP-268: Rack Awareness for Kafka Sources

2022-11-11 Thread Jeremy DeGroot
> > 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 ve

[DISCUSS] FLIP-268: Rack Awareness for Kafka Sources

2022-11-10 Thread Jeremy DeGroot
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

[jira] [Created] (FLINK-29398) Utilize Rack Awareness in Flink Consumer

2022-09-22 Thread Jeremy DeGroot (Jira)
Jeremy DeGroot created FLINK-29398: -- Summary: Utilize Rack Awareness in Flink Consumer Key: FLINK-29398 URL: https://issues.apache.org/jira/browse/FLINK-29398 Project: Flink Issue Type

[jira] [Created] (FLINK-26558) Errors when reporting on Job status

2022-03-09 Thread Jeremy DeGroot (Jira)
Jeremy DeGroot created FLINK-26558: -- Summary: Errors when reporting on Job status Key: FLINK-26558 URL: https://issues.apache.org/jira/browse/FLINK-26558 Project: Flink Issue Type: Bug