हाय मैंने अपाचे काफ्का 0.10.0.0 डाउनलोड किया है। here से आरसी 4, जिसमें क्षमता अब here बताई गई संदेशों को टाइमस्टैम्प संलग्न करती है।अपाचे काफ्का 0.10.0.0 में टाइमस्टैम्प नहीं देख सकता। आरसी 4
मैंने इसे अपने सर्वर पर चलाया है जैसा कि मैं सामान्य रूप से करता हूं और यह लॉग प्राप्त कर रहा है।
लेकिन जब मैं एक विषय देखने के लिए काफ्का उपभोक्ता कंसोल चला रहा हूं, तो लॉग अलग नहीं दिखते हैं और कोई टाइमस्टैम्प नहीं है? उन्हें जेएसओएन में काफ्का भेजा जाता है क्या इससे चीजों को प्रभावित किया जाएगा? क्या आप उन्हें उपभोक्ता कंसोल में देख सकते हैं? अगर नहीं?
मैं यह देखने की कोशिश कर रहा हूं कि मेरी पाइपलाइन के पहले चरण में कितना समय लगता है।
क्या लॉग इन में जोड़ने के लिए कफका प्राप्त करने के लिए वैसे भी है, इसलिए अन्य उपभोक्ता उन्हें देखते हैं (केवल उपभोक्ता कंसोल नहीं)? –
आपका क्या मतलब है? नए पेश किए गए टाइमस्टैम्प (देखें [केआईपी -32] (https://cwiki.apache.org/confluence/display/KAFKA/KIP-32+-+Add+timestamps+to+Kafka+message)) वास्तविक में एम्बेडेड हैं संदेश। –
मेरे में यह नहीं है: यहां मैं कफका को भेजता हूं और यह नहीं बदला है: "{" rsyslog_timestamp ":" 2016-05-18T13: 47: 45.320916 + 00: 00 "," संदेश ":" - - 2016-05-18T13: 47: 45: 320824 \ "प्राप्त करें \/निवेश \/शेयर \/अंतर्राष्ट्रीय-विविधता-शेयर? उपयोगकर्ता = उपयोगकर्ता 158 HTTP \ /1.1 \" 301 692 "}" –