काफ्का सिंक कनेक्टर:पुनरारंभ करने के बाद भी कोई कार्य असाइन नहीं किया गया है

मैंने इस मुद्दे का सामना किया है। यदि सिंकटास्क या सोर्सटास्क शुरू करने के लिए संसाधन कम हैं, तो ऐसा हो सकता है।

कार्यकर्ता को आवंटित स्मृति कुछ समय कम हो सकती है। डिफ़ॉल्ट रूप से श्रमिकों को 250MB आवंटित किया जाता है। कृपया इसे बढ़ाएं। वितरित मोड में चल रहे कार्यकर्ता के लिए 2GB मेमोरी आवंटित करने का एक उदाहरण नीचे दिया गया है।

KAFKA_HEAP_OPTS="-Xmx2G" श $KAFKA_SERVICE_HOME/कनेक्ट-वितरित $KAFKA_CONFIG_HOME/connect-avro-distributed.properties