Resultados de la búsqueda a petición "apache-kafka"
¿Cómo garantizar que un grupo de kafka esté completamente activo?
Tenemos un clúster de cinco nodos ejecutándose en producción con 3 cuidadores de zoológico, todos son máquinas virtuales. Tenemos que reiniciar el clúster a menudo para algunos parches de hardware. Hemos escrito un script ansible para cerrar el ...
KStream envía el registro a varias transmisiones (no a Branch)
¿Hay alguna manera de hacer una operación similar a una rama pero colocar un registro en cada flujo de salida cuyo predicado se evalúa como verdadero? Brach coloca el registro en la primera coincidencia (documentación: se coloca un registro en ...
Kafka Stream Suppress session-windowed-aggregation
He escrito este código en una aplicación de transmisión de Kafka: KGroupedStream<String, foo> groupedStream = stream.groupByKey(); groupedStream.windowedBy( SessionWindows.with(Duration.ofSeconds(3)).grace(Duration.ofSeconds(3))) .aggregate(() ...
¿Cómo hacer que el productor pueda reiniciarse?
a última versión de kafka admite exactamente una vez la semántica (EoS). Para respaldar esta noción, se agregan detalles adicionales a cada mensaje. Esto significa que a su consumidor; Si imprime compensaciones de mensajes, no ...
Kafka Streams no incrementa el desplazamiento en 1 al producir el tema
He implementado un sencillo procesador de registros de letras muertas de Kafka. Funciona perfectamente cuando se utilizan registros producidos por el productor de la consola. Sin embargo, encuentro que nuestras aplicaciones de Kafka Streams no ...
Cómo resolver un problema con __consumer_offsets inválidos y marcados como época de productor en particiones de __transaction_state
Tengo dos tipos de entradas de registro en server.log Primer tipo: WARN Restableciendo el primer desplazamiento sucio de__consumer_offsets-6 para iniciar el inicio de desplazamiento 918 desde elcheckpointed offset 903 no es válido. ...
¿Cómo codificar / decodificar mensajes Kafka usando el codificador binario Avro?
Estoy tratando de usar Avro para los mensajes que se leen / escriben en Kafka. ¿Alguien tiene un ejemplo del uso del codificador binario Avro para codificar / decodificar datos que se colocarán en una cola de mensajes? Necesito la parte Avro ...