అపాచీ కాఫ్కాతో ప్రారంభించడం
అపాచీ కాఫ్కాను ఇన్స్టాల్ చేసే ముందు, మీరు తప్పనిసరిగా జావాను ఇన్స్టాల్ చేసి, సుడో అధికారాలతో వినియోగదారు ఖాతాను కలిగి ఉండాలి. అంతేకాకుండా, కాఫ్కా సరైన రన్నింగ్ కోసం 2GB మరియు అంతకంటే ఎక్కువ RAM కలిగి ఉండాలని సిఫార్సు చేయబడింది.
అపాచీ కాఫ్కాను ఎలా ఇన్స్టాల్ చేయాలో క్రింది దశలు మీకు మార్గనిర్దేశం చేస్తాయి.
జావాను ఇన్స్టాల్ చేస్తోంది
కాఫ్కాను ఇన్స్టాల్ చేయడానికి జావా అవసరం. కింది ఆదేశాన్ని ఉపయోగించి సంస్కరణను తనిఖీ చేయడం ద్వారా మీ ఉబుంటుకు జావా ఇన్స్టాల్ చేయబడిందో లేదో తనిఖీ చేయండి:
$ జావా --సంస్కరణ: Telugu
జావా ఇన్స్టాల్ చేయకపోతే, జావా ఓపెన్జెడికెను ఇన్స్టాల్ చేయడానికి క్రింది ఆదేశాలను ఉపయోగించండి.
$ సుడో సముచితమైన నవీకరణ
$ సుడో సముచితమైనది ఇన్స్టాల్ డిఫాల్ట్-jdk
వినియోగదారు ఖాతాను సృష్టిస్తోంది
ఇప్పటికే ఇన్స్టాల్ చేసిన జావాతో, రూట్ కాని వినియోగదారు ఖాతాను సృష్టించండి. కింది ఆదేశాన్ని ఉపయోగించి సుడో సమూహానికి వినియోగదారుని జోడించడం ద్వారా మనం దానికి కొన్ని సుడో అధికారాలను కూడా ఇవ్వాలి:
$ సుడో adduser linuxhint
$ సుడో adduser linuxhint సుడో
కొత్తగా సృష్టించిన వినియోగదారు ఖాతాకు లాగిన్ చేయండి.
$ దాని -ఎల్ linuxhint
కాఫ్కాను ఇన్స్టాల్ చేస్తోంది
మీరు అధికారిక డౌన్లోడ్ పేజీ నుండి తాజా Apache Kafkaని డౌన్లోడ్ చేసుకోవాలి. ఉపయోగించి దాని బైనరీ ఫైల్లను డౌన్లోడ్ చేయండి wget కింది వాటిలో చూపిన విధంగా ఆదేశం:
$ wget https: // downloads.apache.org / కాఫ్కా / 3.2.3 / kafka_2.12-3.2.3.tgz
బైనరీ ఫైల్ డౌన్లోడ్ అయిన తర్వాత, దాన్ని ఉపయోగించి దాన్ని సంగ్రహించండి తీసుకుంటాడు కమాండ్ చేయండి మరియు సంగ్రహించిన డైరెక్టరీని కు తరలించండి /opt/kafka.
తరువాత, సృష్టించండి systemd స్క్రిప్ట్లు కొరకు జూకీపర్ ఇంకా కాఫ్కా సేవలను ప్రారంభించడంలో మరియు ఆపడంలో సహాయపడే సేవలు.
systemd స్క్రిప్ట్లను సృష్టించడానికి మరియు క్రింది కంటెంట్లను అతికించడానికి ఎంపిక చేసే ఎడిటర్ని ఉపయోగించండి. జూకీపర్తో ప్రారంభించండి:
$ సుడో నానో / మొదలైనవి / systemd / వ్యవస్థ / zookeeper.serviceకింది వాటిని అతికించండి:
[ యూనిట్ ]వివరణ =అపాచీ జూకీపర్ సర్వర్
డాక్యుమెంటేషన్ =http: // zookeeper.apache.org
అవసరం =network.target remote-fs.target
తర్వాత =network.target remote-fs.target
[ సేవ ]
టైప్ చేయండి = సాధారణ
ExecStart = / ఎంపిక / కాఫ్కా / డబ్బా / zookeeper-server-start.sh / ఎంపిక / కాఫ్కా / config / zookeeper.గుణాలు
ExecStop = / ఎంపిక / కాఫ్కా / డబ్బా / zookeeper-server-stop.sh
పునఃప్రారంభించండి = అసాధారణమైనది
[ ఇన్స్టాల్ చేయండి ]
వాంటెడ్ బై =multi-user.target
ఫైల్ను సేవ్ చేయండి. కాఫ్కా కోసం systemd ఫైల్ను సృష్టించండి మరియు కింది విషయాలను అతికించండి:
అతికించేటప్పుడు, మీరు మీ సిస్టమ్లో ఇన్స్టాల్ చేసిన జావా కోసం సరైన మార్గాన్ని సెట్ చేశారని నిర్ధారించుకోండి.
[ యూనిట్ ]వివరణ =అపాచీ కాఫ్కా సర్వర్
డాక్యుమెంటేషన్ =http: // kafka.apache.org / documentation.html
అవసరం = zookeeper.service
[ సేవ ]
టైప్ చేయండి = సాధారణ
పర్యావరణం = 'JAVA_HOME=/usr/lib/jvm/java-11-openjdk-amd64'
ExecStart = / ఎంపిక / కాఫ్కా / డబ్బా / kafka-server-start.sh / ఎంపిక / కాఫ్కా / config / సర్వర్.గుణాలు
ExecStop = / ఎంపిక / కాఫ్కా / డబ్బా / kafka-server-stop.sh
పునఃప్రారంభించండి = అసాధారణమైనది
[ ఇన్స్టాల్ చేయండి ]
వాంటెడ్ బై =multi-user.target
పూర్తయిన తర్వాత, systemd డెమోన్ని మళ్లీ లోడ్ చేయడం ద్వారా మార్పులను వర్తింపజేయండి:
తరువాత, జూకీపర్ సేవను ప్రారంభించండి మరియు కింది ఆదేశాలను ఉపయోగించి దాన్ని ప్రారంభించండి:
$ సుడో systemctl జూకీప్ ప్రారంభం < బలమైన > ఆర్ బలమైన >
మీరు కాఫ్కా కోసం కూడా ఇలాగే చేయాలి:
$ సుడో systemctl కాఫ్కాను ప్రారంభించండి
మీరు సేవలను ప్రారంభించిన తర్వాత, మేము కాఫ్కాలో టాపిక్ను సృష్టించే ముందు మీరు వారి స్థితిని ధృవీకరించవచ్చు.
కాఫ్కాతో ఉన్న మంచి విషయం ఏమిటంటే మీరు ఉపయోగించగల బహుళ స్క్రిప్ట్లు ఉన్నాయి.
అనే కొత్త టాపిక్ని క్రియేట్ చేద్దాం linuxhint1 ఉపయోగించి kafka-topics.sh ఒక విభజన మరియు ప్రతిరూపంతో స్క్రిప్ట్. కింది ఆదేశాన్ని ఉపయోగించండి:
$ సుడో -లో linuxhint / ఎంపిక / కాఫ్కా / డబ్బా / kafka-topics.sh --సృష్టించు --bootstrap-server స్థానిక హోస్ట్: 9092 --ప్రతిరూపణ-కారకం 1 --విభజనలు 1 --విషయం linuxhint1
మా అంశం సృష్టించబడిందని గమనించండి. అలా ధృవీకరించడానికి మనం మునుపటి సందేశాన్ని చూడవచ్చు.
ప్రత్యామ్నాయంగా, మీరు ఉపయోగించి అందుబాటులో ఉన్న అంశాలను జాబితా చేయవచ్చు -జాబితా కింది ఆదేశంలో ఎంపిక. ఇది మేము సృష్టించిన అంశాన్ని తిరిగి ఇవ్వాలి:S
$ సుడో -లో linuxhint / ఎంపిక / కాఫ్కా / డబ్బా / kafka-topics.sh --జాబితా --bootstrap-server స్థానిక హోస్ట్: 9092
కాఫ్కా టాపిక్ సృష్టించబడటంతో, మీరు స్ట్రీమ్ల డేటాను రాయడం ప్రారంభించవచ్చు Kafka-console-producer.sh మరియు అది మీలో ప్రతిబింబిస్తుందో లేదో తనిఖీ చేయండి వినియోగదారు.sh.
కింది వాటిలో చూపిన విధంగా మీ షెల్ తెరిచి, ప్రొడ్యూసర్.sh ఉపయోగించి మేము సృష్టించిన అంశాన్ని యాక్సెస్ చేయండి:
$ సుడో -లో linuxhint / ఎంపిక / కాఫ్కా / డబ్బా / kafka-console-producer.sh --బ్రోకర్-జాబితా స్థానిక హోస్ట్: 9092 --విషయం linuxhint1
తర్వాత, మరొక షెల్ని తెరిచి, వినియోగదారు.shని ఉపయోగించి కాఫ్కా టాపిక్ని యాక్సెస్ చేయండి.
రెండు షెల్లు తెరవబడినప్పుడు, మీరు ప్రొడ్యూసర్ కన్సోల్లో మెసేజ్ చేయవచ్చు. మీరు ఏది టైప్ చేసినా వినియోగదారు కన్సోల్లో మా Apache Kafka అప్ మరియు రన్ అవుతుందని నిర్ధారిస్తుంది.
ముగింపు
ఈ గైడ్తో, మీరు ఇప్పుడు మీ ఉబుంటు 22.04లో అపాచీ కాఫ్కాను ఇన్స్టాల్ చేయడానికి అనుసరించగల అన్ని దశలను కలిగి ఉన్నారు. ఆశాజనక, మీరు ప్రతి దశను అనుసరించి, మీ అపాచీ కాఫ్కాను ఇన్స్టాల్ చేయగలరు మరియు సాధారణ వినియోగదారు మరియు నిర్మాత ఉత్పత్తిని అమలు చేయడానికి టాపిక్లను సృష్టించగలరు. మీరు పెద్ద ఉత్పత్తిలో అదే అమలు చేయవచ్చు.