तारिक - मैं इस विषय का विशेषज्ञ नहीं हूँ। लेकिन मैंने Oracle डेटाबेस के साथ JDBC सिंक एडॉप्टर के साथ भी ऐसा ही करने की कोशिश की है।
आप विषय पर जो डेटा प्रारूप भेज रहे हैं वह मुझे सही नहीं लगता। इसलिए, आपको त्रुटि मिल रही है। चूंकि आप JsonConverter का उपयोग कर रहे हैं, सिंक एडेप्टर को पार्स करने और डेटा स्टोर पर लिखने के लिए विषय की प्रत्येक पंक्ति निम्न प्रारूप में होनी चाहिए। वर्तमान में आपके डेटा में पेलोड में स्कीमा नहीं है। इसलिए त्रुटि।
कृपया नीचे दिए गए विषय को पास करें और देखें कि क्या यह MongoDB में डूब जाता है।
{
"schema": {
"type": "struct",
"fields": [
{
"type": "string",
"optional": false,
"field": "name"
},
{
"type": "string",
"optional": true,
"field": "dept"
},
{
"type": "int64",
"optional": true,
"field": "studentId"
}
],
"optional": false,
"name": "YOUR_TABLE_NAME"
},
"payload": {
"name": "This is a test",
"dept": "siqdj",
"studentId": 1
}
}