Resultados de la búsqueda a petición "apache-kafka"
¿Cuántos productores crear en kafka?
En una aplicación web java en tiempo real de gran volumen, le envío mensajes aapache kafka. Actualmente estoy enviando a un solo tema, pero en el futuro podr...
¿Cuáles son las limitaciones de nombre de tema de Apache Kafka?
Acabo de intentar crear un tema de Kafka"user:created" y vi este error en los registros de Kafka:Invalid character ':' in value part of property. Busqué en Google y descubrí que en una lista de correo la gente habla de despreciar. y_ Símbolos ...
Kafka 0.9.0.1 Java Consumer atascado en awaitMetadataUpdate ()
Estoy tratando de hacer que un Kafka Consumer simple funcione con la API de Java v0.9.0.1. El servidor kafka que estoy usando es un contenedor acoplable, que también ejecuta la versión 0.9.0.1. A continuación se muestra el código ...
Comprender los temas y particiones de Kafka
Estoy empezando a aprender Kafka para propósitos de soluciones empresariales. Durante mis lecturas, me vinieron a la mente algunas preguntas: Cuando un productor está produciendo un mensaje: especificará eltemaquiere enviar el mensaje a, ¿es ...
Lea el tema de Kafka en un trabajo por lotes de Spark
Estoy escribiendo un trabajo por lotes de Spark (v1.6.0) que lee un tema de Kafka. Para esto puedo usarorg.apache.spark.streaming.kafka.KafkaUtils#createRDD sin embargo, necesito establecer las compensaciones para todas las particiones y también ...
Streamparse ejemplo de recuento de palabras
He estado queriendo usar Apache Storm para transmitir desde Kafka. Estoy más cómodo con Python, así que decidí usar streamparse ( https://github.com/Parsely/streamparse [https://github.com/Parsely/streamparse]) El ejemplo de conteo de palabras es ...
Particiones de tema de Kafka a la transmisión de Spark
Tengo algunos casos de uso que me gustaría aclarar, sobre la partición de temas de Kafka -> utilización de recursos de transmisión por chispa. Uso el modo independiente de chispa, por lo que solo las configuraciones que tengo son "número total ...
Opción de máquina virtual no reconocida de Kafka 'PrintGCDateStamps'
Instalé Kafka en un servidor remoto y cuando intenté ejecutar ~/kafka/bin/zookeeper-server-start.sh ~/kafka/config/zookeeper.propertiesY recibí un error Unrecognized VM option 'PrintGCDateStamps'Y el servidor kafka no pudo iniciarse. Esto no se ...