Resultados de la búsqueda a petición "apache-kafka"
Cómo Kafka transmitió a muchos grupos de consumidores
Soy nuevo en Kafka y agradeceré muchas aclaraciones sobre el próximo caso. La documentación de Kafka dice en el párrafo "Posición del consumidor": "Nuestro tema se divide en un conjunto de particiones totalmente ordenadas, cada una de las ...
¿Hay una manera fácil de instalar Kafka en Windows?
Estoy tratando de instalarKafka [http://kafka.apache.org/]cola de mensajes en Windowspara las pruebasPropósito (no para producción: D). Solo encontré este artículo sobre cómo instalar Apache Kafka 0.8 en ...
¿Cómo lograr la tenencia múltiple en el contexto de Kafka y tormenta?
¿Cuáles son las mejores prácticas para construir una aplicación multiinquilino en el contexto de Kafka y tormenta? Por ejemplo: crear un tema para cada inquilino y consumir un pico de varios temas (usando comodines).
Kafka: escribir serializador personalizado
Estoy tratando de construir un POC con Kafka 0.8.1. Estoy usando mi propia clase java como un mensaje Kafka que tiene un montón de tipos de datos de cadena. No puedo usar la clase de serializador predeterminada o la clase de serializador ...
Error de ejemplo de Apache Kafka: no se pudo enviar el mensaje después de 3 intentos
Estoy ejecutando este ejemplo de productor de kafka mencionado en su sitio El código: public class TestProducer { public static void main(String[] args) { long events = Long.parseLong(args[0]); Random rnd = new Random(); Properties props = ...
Kafka Streams - Enviar sobre diferentes temas dependiendo de los datos de Streams
Tengo una aplicación de secuencias de kafka esperando que se publiquen registros sobre el temauser_activity. Recibirá datos json y, dependiendo del valor de una clave, quiero insertar esa secuencia en diferentes temas. Este es mi código de la ...
No escribir datos de compensación al cuidador del zoológico en kafka-storm
Estaba configurando un clúster de tormenta para calcular las tendencias en tiempo real y otras estadísticas, sin embargo, tengo algunos problemas al introducir la función de "recuperación" en este proyecto, al permitir el desplazamiento que fue ...
Reiniciar un consumidor de Kafka (python) consume todos los mensajes de la cola nuevamente
Estoy usando Kafka 0.8.1 y Kafka python-0.9.0. En mi configuración, tengo 2 corredores de kafka configurados. Cuando ejecuto mi consumidor de kafka, puedo verlo recuperando mensajes de la cola y haciendo un seguimiento de las compensaciones para ...
Cómo obtener una lista de temas del servidor kafka en Java
estoy usandokafka 0.8 versión y muy nuevo para ella. Quiero saber la lista de temas creados enkafka server junto con sus metadatos. ¿Hay alguna API disponible para descubrir esto? Básicamente, necesito escribir un consumidor de Java que debería ...
Ejemplo de prueba de Kafka incrustado simple con arranque de resorte
Editar FYI:ejemplo de trabajo de gitHub [https://github.com/YunaBraska/embedded-kafka-example] Estaba buscando en Internet y no pude encontrar un ejemplo funcional y simple de una prueba de Kafka integrada. Mi configuración es: Bota de ...