entrega-kafka

ALUMNOS/MDAA/MAR_SOLER/KAFKA/consumer.py

@@ -0,0 +1,31 @@
+from confluent_kafka import Consumer, KafkaError
+
+config = {
+    'bootstrap.servers': 'localhost:9092',  
+    'group.id': 'python-consumer-group',
+    'auto.offset.reset': 'earliest'  
+}
+
+consumer = Consumer(config)
+
+topic = "recetas"
+consumer.subscribe([topic])
+
+try:
+    while True:
+        msg = consumer.poll(1.0)  # Lee nuevos mensajes cada 1 segundo
+
+        if msg is None:
+            continue
+        if msg.error():
+            if msg.error().code() == KafkaError._PARTITION_EOF:
+                print("No hay más mensajes en esta partición.")
+            else:
+                print("Error al recibir mensaje: {}".format(msg.error()))
+        else:
+            print("Nuevo mensaje: {}".format(msg.value().decode("utf-8")))
+
+except KeyboardInterrupt:
+    pass
+finally:
+    consumer.close()

ALUMNOS/MDAA/MAR_SOLER/KAFKA/producer.py

@@ -0,0 +1,31 @@
+import time
+from json import dumps
+from confluent_kafka import Producer
+import re
+
+config = {
+    'bootstrap.servers': 'localhost:9092',  
+    'client.id': 'python-producer'
+}
+
+producer = Producer(config)
+
+topic_kafka = "recetas"
+
+file1 = open("recetas.txt",encoding="utf8")
+Lines = file1.readlines()
+
+count = 0
+
+for line in Lines:
+    time.sleep(2)
+    print( line.strip() + "\n")
+    words = re.findall(r"[\w']+|[.,!?;]", line)
+    for word in words:
+        data_bytes = word  
+        key = str(count)
+        producer.produce(topic=topic_kafka, value=data_bytes, key=key)
+        producer.flush()
+
+if producer.flush() != 0:
+    print("Error en el envío de algunos mensajes.")

ALUMNOS/MDAA/MAR_SOLER/KAFKA/recetas.txt

@@ -0,0 +1,100 @@
+Paella Valenciana
+Tacos al Pastor
+Enchiladas Verdes
+Pizza Margarita
+Sushi de Salmón
+Hamburguesa Clásica
+Lasagna Boloñesa
+Ceviche Peruano
+Empanadas de Carne
+Falafel con Hummus
+Gazpacho Andaluz
+Moussaka Griega
+Pad Thai
+Ratatouille
+Biryani de Pollo
+Chili con Carne
+Croquetas de Jamón
+Pollo a la Parrilla
+Sopa de Tomate
+Risotto de Champiñones
+Filete de Ternera
+Pescado a la Plancha
+Ensalada César
+Tortilla Española
+Arroz con Leche
+Sopa de Mariscos
+Pollo al Ajillo
+Pasta Carbonara
+Pan de Ajo
+Curry Vegetariano
+Guiso de Lentejas
+Empanadas de Pollo
+Pollo a la Cacciatora
+Fajitas de Res
+Bacalao a la Vizcaína
+Crema de Calabaza
+Quiche Lorraine
+Macarrones con Queso
+Burrito Mexicano
+Sándwich Cubano
+Tarta de Queso
+Churros con Chocolate
+Pollo al Curry
+Arroz Frito
+Sushi de Atún
+Pato a la Naranja
+Minestrone
+Canelones de Espinacas
+Mousse de Chocolate
+Panna Cotta
+Pisto Manchego
+Croissant de Jamón y Queso
+Sopa de Ajo
+Goulash Húngaro
+Bruschetta Italiana
+Focaccia de Romero
+Paella Mixta
+Pollo a la Barbacoa
+Carne Asada
+Chili Vegetariano
+Lasaña de Verduras
+Sushi Vegetariano
+Bocadillo de Calamares
+Ensalada Caprese
+Steak Tartare
+Pollo al Horno
+Crepes Suzette
+Pollo al Chipotle
+Pastel de Carne
+Tortilla de Patatas
+Patatas Bravas
+Salmón al Horno
+Albóndigas en Salsa
+Ensalada Griega
+Calamares a la Romana
+Pechuga de Pollo Rellena
+Ensalada de Quinoa
+Pasta al Pesto
+Croquetas de Pollo
+Fideos de Arroz con Verduras
+Empanada Gallega
+Tiramisú
+Panqueques Americanos
+Chili de Quinoa
+Brócoli al Ajillo
+Nuggets de Pollo Caseros
+Puré de Papas
+Crema de Champiñones
+Pizza Pepperoni
+Pollo con Verduras
+Espaguetis al Pesto
+Ensalada Mixta
+Canelones de Carne
+Gambas al Ajillo
+Risotto de Mariscos
+Merluza en Salsa Verde
+Ensalada de Pasta
+Pechuga a la Plancha
+Lomo Saltado
+Pastel de Chocolate