Я использую Elasti c Поиск Kafka Connect в автономном режиме. Меня не смущает, какую конфигурацию использовать для запуска подключения Kafka и получения с последней точки отказа.
Например, производитель будет продолжать загружать записи в Kafka и Consumer как Elasti c Соединитель приемника поиска потребляет, теперь мой по какой-то причине мой потребитель не работает, но мой гордый продолжит посылать сообщения в Кафку. Теперь, когда я исправил свою проблему на стороне разъема приемника ES, и если я перезапустил разъем приемника ES, он должен выбрать последний сбой не с начала или с последнего, а с последнего сбоя. Если с момента сбоя поступило 10 сообщений, то при запуске разъема приемника ES он должен сначала принять 10, а затем самое последнее.
Пожалуйста, помогите с настройкой.