Resultados de la búsqueda a petición "apache-kafka"
¿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 ...
kafka.consumer.SimpleConsumer: Reconectarse debido a un error de socket: java.nio.channels.ClosedChannelException
Estoy ejecutando un consumidor simple para kafka como este: int timeout = 80000; int bufferSize = 64*1024; consumer = new SimpleConsumer(host, port,timeout, bufferSize, clientName);Esto funciona bien durante un par de horas, pero recibo una ...
Kafka Crear opciones de API de tema para lenguajes no Java
Si bien puede crear un tema a través de Java o lenguajes basados en Java (consulteaquí [https://stackoverflow.com/questions/18225263/kafka-0-8-is-it-possible-to-create-topic-with-partition-and-replication-using-j] ), no parece haber una forma ...
Datos de replicación de Oracle usando Apache kafka
Me gustaría exponer la tabla de datos de mi base de datos Oracle y exponerla en apache kafka. ¿Es técnicamente posible? Además, necesito transmitir el cambio de datos desde mi tabla Oracle y notificarlo a Kafka. ¿Conoces buena documentación de ...
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 ...
No es capaz de ver kafka.consumer y kafka.producer mBean en jConsole
EDIT:Vengo a conocer t [https://stackoverflow.com/questions/37799564/kafka-consumer-jmx-properties]que debería habilitar JMX en mis procesos de consumidor y productor y obtener información de mBean de los procesos respectivos. ¿Cómo haré esto ...
¿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: no se pueden crear múltiples consumidores de flujo
Me puse en marcha con Kafka 0.8 beta 1. Tengo un ejemplo muy simple en funcionamiento, el problema es que solo puedo hacer que un consumidor de mensajes func...