Resultados de la búsqueda a petición "apache-kafka"
Kafka Connect se queda sin espacio de almacenamiento dinámico
Después de iniciar Kafka Connect (connect-standalone), mi tarea falla inmediatamente después de comenzar con: java.lang.OutOfMemoryError: Java heap space at java.nio.HeapByteBuffer.<init>(HeapByteBuffer.java:57) ...
¿Desplazamientos almacenados en Zookeeper o Kafka?
Estoy un poco confundido acerca de dónde se almacenan las compensaciones cuando uso Kafka y Zookeeper. Parece que las compensaciones en algunos casos se almacenan en Zookeeper, en otros casos se almacenan en Kafka. ¿Qué determina si el ...
Cómo manejar el error y no comprometerse cuando use Kafka Streams DSL
Para Kafka Streams, si usamos una API de procesador de nivel inferior, podemos controlar la confirmación o no. Entonces, si ocurren problemas en nuestro código, y no queremos confirmar este mensaje. En este caso, Kafka reenviará este mensaje ...
Apache Kafka y Avro: org.apache.avro.generic.GenericData $ Record no se puede enviar a com.harmeetsingh13.java.Customer
Cada vez que intento leer el mensaje de la cola kafka, recibo la siguiente excepción: [error] (run-main-0) java.lang.ClassCastException: org.apache.avro.generic.GenericData$Record cannot be cast to com.harmeetsingh13.java.Customer ...
¿Por qué el consumidor de Kafka tarda tanto en comenzar a consumir?
Comenzamos un consumidor de Kafka, escuchando un tema que aún no se ha creado (aunque la creación automática de temas está habilitada). No mucho tiempo después, un productor publica mensajes sobre ese tema. Sin embargo, al consumidor le lleva ...
Servidores de arranque Kafka vs zookeeper en kafka-console-consumer
Estoy tratando de probar ejecutar un solo nodo Kafka con 3 corredores y cuidador del zoológico. Deseo probar usando las herramientas de la consola. Dirijo el productor como tal: kafka-console-producer ...
¿Cómo puedo obtener el valor de compensación en KStream?
Estoy desarrollando un PoC con Kafka Streams. Ahora necesito obtener el valor de compensación en el consumidor continuo y usarlo para generar una clave única(topic-offset)->hash para cada mensaje La razón es que los productores son syslog y solo ...
Consultas externas del sistema durante el procesamiento de Kafka Stream
Estoy tratando de diseñar una arquitectura de transmisión para análisis de transmisión. Requisitos: Entrada de datos de transmisión RT y NRTProcesadores de flujo que implementan algunos análisis financierosFlujo de salida de análisis RT y ...
Cómo obtener compensaciones de grupo de consumidores para la partición en Golang Kafka 10
Ahora que la biblioteca Golang Kafka (sarama) proporciona capacidad de grupo de consumidores sin ninguna ayuda de biblioteca externa con kafka 10. ¿Cómo puedo obtener el desplazamiento del mensaje actual que está siendo procesado por un grupo de ...
Compruebe si el sistema está conectado a Kafka
Necesito escribir una prueba de humo en Java que valide si el sistema está conectado a kafka, ¿Alguien tiene alguna idea? He encontrado esta publicación: ¿Cómo verificar si se está ejecutando Kafka ...