Реших тази грешка, като направих следните промени
- insert.mode=insert
- Коментирайте table.name.format=kafkatable, защото таблицата ще бъде създадена чрез автоматично създаване
- Премахнете въпросителния знак от края на реда connection.url.
- pk.fields не трябва да се съхраняват none тук, моля, не забравяйте да дадете име на колона вместо това, за да избегнете усложнения.
- int32 не се поддържа от postgresql, така че когато го промених на int8, работи добре.
- Полетата във вашата схема и полезен товар имат различни имена, моля, уверете се, че давате едно и също име.
