<prompt> Anzisha programu ya Python ambayo huwasiliana na nguzo ya Kafka, hutoa ujumbe kwa mada, hutumia ujumbe kutoka kwa mada sawa, na kuchakata ujumbe unaotumiwa kwa kutumia algoriti maalum k.m., hesabu ya maneno, uchanganuzi wa hisia.  <response>: Ili kukuza programu ya Python inayowasiliana na nguzo ya Kafka, utahitaji kusakinisha maktaba ya kafka-python. Unaweza kufanya hivyo kwa kutumia pip:bashibomba kufunga kafka-pythonSasa hebu tuunde mtayarishaji rahisi na mtumiaji kwa mada ya Kafka.1. Mtayarishaji: Hii itatoa ujumbe kwa mada ya Kafka.2. Mtumiaji: Hii itatumia ujumbe kutoka kwa mada sawa ya Kafka.3. Inachakata: Tutatumia algoriti rahisi ya kuhesabu maneno kuchakata ujumbe unaotumiwa.Hapa kuna nambari kamili: chatukutoka kwa kafka kuagiza KafkaProducer, KafkaConsumerkuagiza jsonkutoka kwa makusanyo leta defaultdict Kazi ya kuunda mtayarishaji wa Kafkadef create_producer: return KafkaProducerbootstrap_serverslocalhost:9092, value_serializerlambda v: json.dumpsv.encodeutf-8 Kazi ya kuunda mtumiaji wa Kafkadef create_consumermada: rudisha KafkaConsumermada, bootstrap_serverslocalhost:9092, value_deserializerlambda m: json.loadsm.decodeutf-8 Kazi ya kutuma ujumbe kwa mada ya Kafkadef send_messagesmtayarishaji, mada, ujumbe: kwa ujumbe katika ujumbe: producer.tumamada, ujumbe producer.flush Kazi ya kutumia ujumbe kutoka kwa mada ya Kafka na kuzichakata kwa kutumia algorithm ya hesabu ya manenodef consume_and_process_messagesmtumiaji: word_count defaultdictint kwa ujumbe kwa watumiaji: maneno message.value.split kwa neno kwa maneno: neno_hesabuneno 1 printHesabu ya Neno Iliyosasishwa:, dictword_countkama __name__ __main__: Unda mtayarishaji wa Kafka mtayarishaji create_producer Tuma ujumbe kwa mada ya Kafka mada mada ya majaribio messages Hujambo ulimwengu, Kafka ni nzuri, Python ni nzuri send_messagesmtayarishaji, mada, jumbe Unda mtumiaji wa Kafka mtumiaji create_consumermada Tumia na usindika ujumbe kutoka kwa mada ya Kafka tumia_na_chakata_ujumbemtumiajiBadilisha localhost:9092 na anwani ya seva ya bootstrap ya nguzo ya Kafka. Mfano huu unadhani kuwa una mfano wa Kafka kwenye mashine yako ya karibu.Ili kuendesha programu hii, hakikisha kuwa una wakala wa Kafka anayefanya kazi ndani ya nchi au sasisha kigezo cha bootstrap_servers ili kuelekeza kwa wakala wako wa mbali wa Kafka. Kisha tekeleza hati ya Python:bashipython kafka_producer_consumer.pyMatokeo yanapaswa kuonyesha hesabu ya maneno iliyosasishwa kwa kila ujumbe unaotumiwa kutoka kwa mada ya Kafka:Hesabu ya Maneno Iliyosasishwa: Hujambo: 1, ulimwengu: 1Hesabu ya Maneno Iliyosasishwa: Hujambo: 1, dunia: 1, Kafka: 1, ni: 1, kubwa: 1Hesabu ya Maneno Iliyosasishwa: Hujambo: 1, ulimwengu: 1, Kafka: 1, ni: 1, kubwa: 1, Python: 1, ajabu: 1Huu ni mfano rahisi wa kutoa na kutumia ujumbe kwa kutumia Kafka katika Python. Unaweza kurekebisha kazi ya kuchakata ili kutekeleza algoriti changamano zaidi kama vile uchanganuzi wa maoni au kazi nyinginezo za kuchakata data. 