में ऑफसेट 0.10 में यह हम साथ एक विशिष्ट स्थान के लिए ऑफसेट रीसेट कर सकते हैं लगता है की तलाश() लेखन कोड केरीसेट उपभोक्ता काफ्का 0.10
कम वहाँ एक कमांड लाइन इस के लिए util है? ऐसा प्रतीत नहीं होता है, अब तक?
में ऑफसेट 0.10 में यह हम साथ एक विशिष्ट स्थान के लिए ऑफसेट रीसेट कर सकते हैं लगता है की तलाश() लेखन कोड केरीसेट उपभोक्ता काफ्का 0.10
कम वहाँ एक कमांड लाइन इस के लिए util है? ऐसा प्रतीत नहीं होता है, अब तक?
मैंने इस उद्देश्य के लिए अभी एक सरल कमांड लाइन उपकरण लागू किया है - https://github.com/serejja/kafka-offset-mgr।
यदि आवश्यक हो तो इसे बाहर करने और मुद्दों/पीआर पोस्ट करने के लिए स्वतंत्र महसूस करें।
पर रीसेट करने की अनुमति नहीं देता है धन्यवाद! यह ठीक वैसा ही है जैसा मुझे चाहिए। – Brandon
इसके नाम के विपरीत होने के विपरीत, आप गैर कफका स्ट्रीम अनुप्रयोगों के लिए 'कफका-स्ट्रीम-एप्लिकेशन-रीसेट' स्क्रिप्ट का उपयोग कर सकते हैं '$ KAFKA_HOME/bin/kafka-streams-plication-reset.sh --zookeeper zk: 2181 - अनुप्रयोग-आईडी myGroupId - इनपुट-विषय myTopic' – Raf
'kafka-streams-application-reset' केवल सबसे पुरानी ऑफ़सेट स्थिति पर रीसेट हो जाता है। यह आपको _specific_ स्थिति – sworisbreathing