Я запускаю приемник с неправильным преобразованием, которое создает неправильные данные в таблице приемника mysql, но когда я исправляю конфигурацию приемника с помощью PUT rest API и запускаю его, он работает успешно, но не обновляет существующие данные в таблице приемника?
kafka connector update rest api не обновлять данные приемника
Ответы (1)
Если ваши данные никем не используются, вы можете использовать следующий шаг:
- стопор sorce и сливной разъем,
- чистые данные из кафки темы,
- чистые данные стоковой БД по определенным темам,
- удалить (или переименовать) тему истории таблиц из кафки
- изменить название коннектора источника
- запустить оба разъема.
person
sonu
schedule
23.08.2019
Да, вы правы, но я уже использую данные kafka и данные db из источника и приемника.
- person ankit; 23.08.2019
