Resultados de la búsqueda a petición "apache-kafka"
Kafka QuickStart, advertised.host.name da kafka.common.LeaderNotAvailableException
Puedo obtener un Kafka simple de un nodo (kafka_2.11-0.8.2.1) trabajando localmente en una máquina Linux, pero cuando intento ejecutar un productor de forma remota, obtengo algunos errores confusos. Estoy siguiendo la guía de inicio rápido ...
¿Cómo uso múltiples consumidores en Kafka?
Soy un nuevo estudiante que estudia Kafka y me he encontrado con algunos problemas fundamentales al comprender a múltiples consumidores con los que los artículos, documentaciones, etc. no han sido demasiado útiles hasta ahora. Una cosa que he ...
¿Por qué el rendimiento del consumidor de Kafka es lento?
Tengo un tema simple y un consumidor y productor de Kafka simple, usando la configuración predeterminada. El programa es muy simple, tengo dos hilos. En el productor, sigue enviando datos de 16 bytes. Y en el lado del consumidor, sigue ...
¿Qué comando muestra todos los temas y compensaciones de particiones en Kafka?
Estoy buscando un comando Kafka que muestre todos los temas y las compensaciones de las particiones. Si es dinámicamente sería perfecto. En este momento estoy usando el código de Java para ver esta información, pero es muy inconveniente.
Monitoreo de kafka usando JMX cuando se ejecuta kafka en docker en boot2docker
Estoy tratando de hacer que el monitoreo JMX funcione para monitorear una instancia de kafka de prueba. Tengo kafka (ches / kafka) ejecutándose en docker a través de boot2docker, pero no puedo configurar la monitorización JMX correctamente. He ...
Abastecimiento de eventos con transmisiones de Kafka
Estoy tratando de implementar una simple prueba de concepto CQRS / fuente de eventos además deKafka arroyos [https://kafka.apache.org/documentation/streams/] (como se describe ...
¿Cómo monitorear el corredor Kafka usando jmxtrans?
Kafka 0.8.1.1 (kafka_2.8.0-0.8.1.1.tgz) Estoy usando jmxtrans para monitorear JMX de una instancia de Kafka (que se ejecuta en docker). Desafortunadamente, las métricas de kafka no se devuelven. He intentado algunas cosas para depurar esto y sé ...
¿Cómo usar Flink's KafkaSource en Scala?
Estoy tratando de ejecutar un programa de prueba simple con KafkaSource de Flink. Estoy usando lo siguiente: Flink 0.9Scala 2.10.4Kafka 0.8.2.1Seguí los documentos para probar KafkaSource (dependencia agregada, agrupar el conector Kafka ...
java.lang.ClassNotFoundException: kafka.api.OffsetRequest
Recibo el error java.lang.ClassNotFoundException kafka.api.OffsetRequest al intentar integrar Kafka a nuestra topología Storm. ¿Qué versiones estás ejecutando y está funcionando? Mi pom.xml <dependency> ...
Kafka - Implementación de cola retrasada usando consumidores de alto nivel
Desea implementar un consumidor retrasado utilizando la API de consumidor de alto nivel idea principal: producir mensajes por clave (cada mensaje contiene la marca de tiempo de creación) esto asegura que cada partición haya ordenado mensajes ...