Resultados de la búsqueda a petición "apache-kafka"
¿Es kafka consumer 0.9 compatible con versiones anteriores?
¿El próximo consumidor kafka 0.9.x será compatible con el corredor 0.8? En otras palabras, ¿es posible cambiar solo a la implementación de un nuevo consumidor, sin tocar nada más?
Kafka cómo leer del tema __consumer_offsets
Estoy tratando de averiguar qué compensaciones están trabajando mis consumidores actuales de alto nivel. Yo uso Kafka 0.8.2.1, conNo"offset.storage" establecido en el server.properties de Kafka, lo que, creo, significa que las compensaciones se ...
No se pudieron encontrar líderes para Set ([TOPICNNAME, 0])) Cuando estamos usando Apache Saprk
Estamos usando Apache Spark 1.5.1 y kafka_2.10-0.8.2.1 y Kafka DirectStream API para obtener datos de Kafka usando Spark. Creamos los temas en Kafka con la siguiente configuración ReplicationFactor: 1 y Replica: 1 Cuando se ejecutan todas las ...
El tema de Kafka ya no existe después de reiniciar
Creé un tema en mi clúster kafka local con 3 servidores / intermediarios ejecutando lo siguiente desde mi directorio de instalación kafka bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 2 --partitions 2 --topic ...
Kafka consumidor compensa el valor máximo?
Estaba buscando en Google y leyendo la documentación de Kafka, pero no pude encontrar el valor máximo de una compensación del consumidor y si hay una compensación envolvente después del valor máximo. Entiendo que offset es un valor Int64, por lo ...
Spark: procesando múltiples temas kafka en paralelo
estoy usandospark 1.5.2. Necesito ejecutar un trabajo de transmisión por chispa con kafka como fuente de transmisión. Necesito leer de múltiples temas dentro de kafka y procesar cada tema de manera diferente. ¿Es una buena idea hacer esto en el ...
¿Cómo configurar / conectar corredores, productores y consumidores de Kafka distribuidos en una red local?
He configurado Apache Kafka y he confirmado que los productores y consumidores trabajan en el host local. Cómo configurar Kafka para que: múltiples productores envían mensajes a un agente en una computadora de redmuchos consumidores en la red ...
diferencia entre groupid y consumerid en Kafka consumidor
Soy nuevo en Kafka. Noté en la configuración del consumidor que tiene dos identificadores. uno es group.id (obligatorio) y el segundo es consumer.id (no obligatorio). Indique por qué 2 ID y diferencia.
no se puede conectar al servidor kafka
Intento usar Kafka con la versión 0.9.0 con el puerto 9092. Si uso telnet, me conecto con éxito a esta dirección, pero no puedo conectarme al servidor Kafka con la API de Java Aquí está mi ejemplo de Java, use exactamente la documentación ...
Karaf - Paquete OSGI de Kafka - Problema del productor
Estoy tratando de crear un paquete simple para el productor de Kafka en apache Karaf versión 4.0.3. Aquí está mi código Java Properties props = new Properties(); props.put("bootstrap.servers", "localhost:9092"); props.put("acks", "all"); ...