मैंने निम्नलिखित परिवर्तन करके इस त्रुटि को हल किया
- insert.mode=insert
- टिप्पणी करें table.name.format=kafktable क्योंकि तालिका स्वतः निर्मित के माध्यम से बनाई जाएगी
- connection.url लाइन के अंत से प्रश्नवाचक चिह्न हटा दें।
- pk.fields को यहां कोई नहीं रखा जाना चाहिए, जटिलताओं से बचने के लिए कृपया इसके बजाय एक कॉलम नाम देना सुनिश्चित करें।
- int32 postgresql द्वारा समर्थित नहीं है, इसलिए जब मैंने इसे int8 में बदल दिया तो यह ठीक काम कर रहा है।
- आपके स्कीमा और पेलोड में अलग-अलग नाम हैं, कृपया एक ही नाम देना सुनिश्चित करें।
