Resultados de la búsqueda a petición "apache-kafka"
Conectar dinámicamente un flujo de entrada de Kafka a múltiples flujos de salida
¿Existe una funcionalidad integrada en Kafka Streams que permita conectar dinámicamente una única secuencia de entrada en múltiples secuencias de salida?KStream.branch permite la ramificación basada en predicados verdaderos / falsos, pero esto no ...
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 ...
No se puede encontrar el tema al generar mensajes: UNKNOWN_TOPIC_OR_PARTITION
Tengo un clúster kafka de dos nodos (instancias EC2) donde cada nodo se usa como un agente independiente. Cuando ejecuto un productor en la instancia líder con el siguiente comando: kafka-console-producer.sh --broker-list localhost:9092 --topic ...
Probar la topología de Kafka Streams
Estoy buscando una forma de probar una aplicación Kafka Streams. Para poder definir los eventos de entrada y el conjunto de pruebas me muestra la salida. ¿Es esto posible sin una configuración real de Kafka?
¿Cómo administrar Kafka KStream a Kstream con ventana?
Residencia enApache Kafka docs [https://kafka.apache.org/documentation/streams#streams_dsl_joins] KStream-to-KStream Joins are always windowed joins, mi pregunta es ¿cómo puedo controlar el tamaño de la ventana? ¿Es del mismo tamaño para ...
¿Cuál es la diferencia en Kafka entre un coordinador de grupo de consumidores y un líder de grupo de consumidores?
Veo referencias a los coordinadores de Kafka Consumer Group y a los líderes de los grupos de consumidores ... ¿Cuál es la diferencia? ¿Cuál es el beneficio de separar la administración del grupo en dos conjuntos diferentes de responsabilidades?
Cómo convertir JavaPairInputDStream en DataSet / DataFrame en Spark
Estoy tratando de recibir datos de transmisión dekafka. En este proceso, puedo recibir y almacenar los datos de transmisión enJavaPairInputDStream. Ahora necesito analizar estos datos sin almacenarlos en ninguna base de datos, así que quiero ...
Error de obtención NoClassDefFoundError: org.apache.spark.internal.Logging en Kafka Spark Stream
Recibo un error en el tiempo de ejecución al ejecutar debajo del código de Java, ¿Hay alguna dependencia que deba incluir para iniciar sesión como log4js o algo así? ¿Por qué este error no aparece en tiempo de compilación para que sea más ...
¿Hay alguna razón para usar RabbitMQ sobre Kafka?
Me pidieron que evaluara RabbitMQ en lugar de Kafka, pero me resultó difícil encontrar una razón por la que está haciendo algo mejor que Kafka. ¿Alguien sabe si es realmente mejor en rendimiento, durabilidad, latencia o facilidad de uso?
Cómo ver la retención de un tema en particular en kafka
Quiero ver el período de retención establecido para un tema en particular. ¿Hay algún comando? Lo intenté conbin/kafka-topics.sh --zookeeper hostname:2181 --alter --config retention.ms=172800000 --topic <topic_name> para eliminar datos de 2 días ...