Hi, the Kafka connector is able to handle leader changes.
On Wed, May 4, 2016 at 5:46 PM, Fabian Hueske <fhue...@gmail.com> wrote: > Sorry, I confused the mail threads. We're already on the user list :-) > Thanks for the suggestion. > > 2016-05-04 17:35 GMT+02:00 Fabian Hueske <fhue...@gmail.com>: > >> I'm not so much familiar with the Kafka connector. >> Can you post your suggestion to the user or dev mailing list? >> >> Thanks, Fabian >> >> 2016-05-04 16:53 GMT+02:00 Sendoh <unicorn.bana...@gmail.com>: >> >>> Glad to see it's developing. >>> Can I ask would the same feature (reconnect) be useful for Kafka >>> connector ? >>> For example, if the IP of broker changes. >>> >>> >>> >>> -- >>> View this message in context: >>> http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Any-way-for-Flink-Elasticsearch-connector-reflecting-IP-change-of-Elasticsearch-cluster-tp6597p6688.html >>> Sent from the Apache Flink User Mailing List archive. mailing list >>> archive at Nabble.com. >>> >> >> >
