Resultados de la búsqueda a petición "apache-kafka"
Utilice el esquema para convertir mensajes AVRO con Spark a DataFrame
¿Hay alguna manera de usar un esquema para convertir avro [/questions/tagged/avro] mensajes de kafka [/questions/tagged/kafka] conchisp [/questions/tagged/spark] amarco de dato [/questions/tagged/dataframe]? El archivo de esquema para registros ...
¿Cómo exponer el método Java para Kafka (commitSync con particiones) en Scala?
Estoy tratando de exponer el método Java a través de Scala (más detalles sobre el método original de Java; proviene de ...
KSQL AVRO FORMAT ISSUE para Kafka Connect Elastic Search: org.apache.kafka.connect.errors.DataException: de ****** ense
Se está lanzando una excepción para Elastic Search Connector: [2018-05-07 11:40:38,975] ERROR WorkerSinkTask{id=elasticsearch-sink-0} Task threw an uncaught and unrecoverable ...
Cómo garantiza Kafka cero tiempo de inactividad y cero pérdida de datos?
Ya pasó sobre Kafka. Pero no sé cómo logra cero tiempo de inactividad y cero pérdidas.
Confluent 4.1.0 -> KSQL: unión STREAM-TABLE -> datos de tabla nulos
PASO 1: Ejecute el productor para crear datos de muestra ./bin/kafka-avro-console-producer \ --broker-list localhost:9092 --topic stream-test-topic \ --property schema.registry.url=http://localhost:8081 ...
Cómo escribir a los consumidores de Kafka: subprocesos individuales o subprocesos múltiples
He escrito un solo consumidor de Kafka (usando Spring Kafka), que lee de un solo tema y es parte de un grupo de consumidores. Una vez que se consume un mensaje, realizará todas las operaciones posteriores y pasará al siguiente desplazamiento del ...
Kafka Resiliency - Coordinador de grupo
egún tengo entendido, uno de los corredores es seleccionado como el coordinador del grupo que se encarga del reequilibrio del consumidor. Discovered coordinator host:9092 (id: 2147483646 rack: null) for group good_group Tengo 3 nodos con factor ...
Spring Kafka Configuración SSL en la aplicación de arranque Spring.yml
Estoy tratando de configurar una aplicación Spring Boot con un cliente Kafka para usar SSL. Tengo mis keystore.jks y truststore.jks almacenados en un sistema de archivos (en un contenedor acoplable) debido a ...
Kafka incrustado: KTable + KTable leftJoin produce registros duplicados
Vengo a buscar el conocimiento de lo arcano. Primero, tengo dos pares de temas, con un tema en cada par alimentando al otro tema. Se están formando dos KTables por los últimos temas, que se utilizan en un KTable + KTable leftJoin. El problema es ...
¿Es posible usar la combinación izquierda múltiple en una consulta KSQL confluente? intentó unir stream con más de 1 tablas, si no, ¿cuál es la solución?
Stream: describe ammas; Field | Type ------------------------------------- ROWTIME | BIGINT (system) ROWKEY | VARCHAR(STRING) (system) ID | INTEGER -------------------------------------Para las estadísticas de tiempo de ejecución y los detalles ...