Resultados de la búsqueda a petición "kafka-python"
NoBrokersAvailable: NoBrokersAvailable-Kafka Error
Ya empecé a aprender Kafka. Intentando operaciones básicas en él. Me he quedado estancado en un punto sobre los 'Brokers'. Mi kafka se está ejecutando pero cuando quiero crear una partición. from kafka import TopicPartition (ERROR THERE) ...
kafka-python - ¿Cómo confirmo una partición?
Usando kafka-python-1.0.2. Si tengo un tema con 10 particiones, ¿cómo hago para confirmar una partición en particular, mientras recorro varias particiones y mensajes? Simplemente no puedo encontrar un ejemplo de esto en ningún lado, en los ...
¿Cómo pasar datos de Kafka a Spark Streaming?
Estoy tratando de pasar datos de kafka a la transmisión por chispa. Esto es lo que he hecho hasta ahora: Instalado amboskafka ysparkEmpezadozookeeper con configuración de propiedades predeterminadaEmpezadokafka server con configuración de ...
Política óptima de retención y eliminación de Kafka
Soy bastante nuevo en kafka, así que perdóname si esta pregunta es trivial. Tengo una configuración muy simple para propósitos de pruebas de tiempo como sigue: Máquina A -> escribe en el tema 1 (Intermediario) -> Máquina B lee del tema 1 Máquina ...