2016-05-12 12 views
7

हाय मैंने अपाचे काफ्का 0.10.0.0 डाउनलोड किया है। here से आरसी 4, जिसमें क्षमता अब here बताई गई संदेशों को टाइमस्टैम्प संलग्न करती है।अपाचे काफ्का 0.10.0.0 में टाइमस्टैम्प नहीं देख सकता। आरसी 4

मैंने इसे अपने सर्वर पर चलाया है जैसा कि मैं सामान्य रूप से करता हूं और यह लॉग प्राप्त कर रहा है।

लेकिन जब मैं एक विषय देखने के लिए काफ्का उपभोक्ता कंसोल चला रहा हूं, तो लॉग अलग नहीं दिखते हैं और कोई टाइमस्टैम्प नहीं है? उन्हें जेएसओएन में काफ्का भेजा जाता है क्या इससे चीजों को प्रभावित किया जाएगा? क्या आप उन्हें उपभोक्ता कंसोल में देख सकते हैं? अगर नहीं?

मैं यह देखने की कोशिश कर रहा हूं कि मेरी पाइपलाइन के पहले चरण में कितना समय लगता है।

उत्तर

14

डिफ़ॉल्ट रूप से टाइमस्टैम्प को कंसोल उपभोक्ता चलाने पर नहीं दिखाया जाता है। आप एक प्रॉपर्टी सेटिंग के माध्यम इसे सक्षम करना चाहिए:

# `print.timestamp=true` requires Kafka 0.10.0+ 
$ kafka-console-consumer.sh --property print.timestamp=true [...] 

Btw, आप भी तो यह है कि सांत्वना उपभोक्ता भी एक काफ्का संदेश के प्रमुख प्रिंट --property print.key=true जोड़ने पर विचार कर सकते हैं।

इसके अलावा, कफका को लिखने वाले आवेदन को नए कफका 0.10 संदेश प्रारूप का समर्थन करना चाहिए, जिसमें नए एम्बेडेड टाइमस्टैम्प शामिल हैं। शायद आप टाइमस्टैम्प नहीं देख सकते क्योंकि अपस्ट्रीम एप्लिकेशन/निर्माता ने कभी भी शामिल नहीं किया है।

+0

क्या लॉग इन में जोड़ने के लिए कफका प्राप्त करने के लिए वैसे भी है, इसलिए अन्य उपभोक्ता उन्हें देखते हैं (केवल उपभोक्ता कंसोल नहीं)? –

+0

आपका क्या मतलब है? नए पेश किए गए टाइमस्टैम्प (देखें [केआईपी -32] (https://cwiki.apache.org/confluence/display/KAFKA/KIP-32+-+Add+timestamps+to+Kafka+message)) वास्तविक में एम्बेडेड हैं संदेश। –

+0

मेरे में यह नहीं है: यहां मैं कफका को भेजता हूं और यह नहीं बदला है: "{" rsyslog_timestamp ":" 2016-05-18T13: 47: 45.320916 + 00: 00 "," संदेश ":" - - 2016-05-18T13: 47: 45: 320824 \ "प्राप्त करें \/निवेश \/शेयर \/अंतर्राष्ट्रीय-विविधता-शेयर? उपयोगकर्ता = उपयोगकर्ता 158 HTTP \ /1.1 \" 301 692 "}" –

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