मुझे विषयों की सूची के लिए कफका से पूछने का एक तरीका ढूंढना होगा। मुझे पता है कि bin\
निर्देशिका में kafka-topics.sh
स्क्रिप्ट का उपयोग करके मैं ऐसा कर सकता हूं। एक बार मेरे पास यह सूची हो जाने के बाद, मुझे प्रति विषय सभी उपभोक्ताओं की आवश्यकता है। मुझे उस निर्देशिका में एक स्क्रिप्ट नहीं मिली, न ही kafka-consumer-api
लाइब्रेरी में एक वर्ग जो मुझे ऐसा करने की अनुमति देता है।काफ्का उपभोक्ता सूची
इसका कारण यह है कि मुझे विषय के ऑफ़सेट और उपभोक्ताओं के ऑफसेट के बीच का अंतर जानने की आवश्यकता है।
क्या यह हासिल करने का कोई तरीका है? या क्या मुझे अपने प्रत्येक उपभोक्ताओं में इस कार्यक्षमता को लागू करने की आवश्यकता है?
हम का उपयोग करना चाहिए --zookeeper --bootstrap-सर्वर नहीं –
0.9.0.0 संस्करण –
लेकिन 0.9.0.0 काफ्का का एक प्राचीन संस्करण नहीं है :) –