2016-07-07 29 views
7

में ऑफसेट 0.10 में यह हम साथ एक विशिष्ट स्थान के लिए ऑफसेट रीसेट कर सकते हैं लगता है की तलाश() लेखन कोड केरीसेट उपभोक्ता काफ्का 0.10

कम वहाँ एक कमांड लाइन इस के लिए util है? ऐसा प्रतीत नहीं होता है, अब तक?

+2

इसके नाम के विपरीत होने के विपरीत, आप गैर कफका स्ट्रीम अनुप्रयोगों के लिए 'कफका-स्ट्रीम-एप्लिकेशन-रीसेट' स्क्रिप्ट का उपयोग कर सकते हैं '$ KAFKA_HOME/bin/kafka-streams-plication-reset.sh --zookeeper zk: 2181 - अनुप्रयोग-आईडी myGroupId - इनपुट-विषय myTopic' – Raf

+0

'kafka-streams-application-reset' केवल सबसे पुरानी ऑफ़सेट स्थिति पर रीसेट हो जाता है। यह आपको _specific_ स्थिति – sworisbreathing

उत्तर

2

मैंने इस उद्देश्य के लिए अभी एक सरल कमांड लाइन उपकरण लागू किया है - https://github.com/serejja/kafka-offset-mgr

यदि आवश्यक हो तो इसे बाहर करने और मुद्दों/पीआर पोस्ट करने के लिए स्वतंत्र महसूस करें।

+0

पर रीसेट करने की अनुमति नहीं देता है धन्यवाद! यह ठीक वैसा ही है जैसा मुझे चाहिए। – Brandon

संबंधित मुद्दे