Resultados de la búsqueda a petición "apache-kafka"
¿Cómo conectarse a múltiples clústeres en una sola aplicación Kafka Streams?
En elGuía para desarrolladores de Kafka Streams [https://docs.confluent.io/current/streams/developer-guide/config-streams.html] dice: Las aplicaciones de Kafka Streams solo pueden comunicarse con un solo clúster de Kafka especificado por este ...
Listar todos los temas de kafka
Estoy usandokafka 0.10sincuidador del zoológico. Quiero obtener la lista de temas kafka. Este comando no funciona ya que no estamos usando zookeeper:bin/kafka-topics.sh --list --zookeeper localhost:2181. ¿Cómo puedo obtener el mismo resultado sin ...
El conector del sumidero Kafka Connect JDBC no funciona
Estoy tratando de usar el conector de sumidero Kafka Connect JDBC para insertar datos en Oracle, pero arroja un error. He intentado con todas las configuraciones posibles del esquema. Debajo están los ejemplos. Sugiera si me falta algo a ...
No puede persistir el DStream para su uso en el próximo lote
JavaRDD<String> history_ = sc.emptyRDD(); java.util.Queue<JavaRDD<String> > queue = new LinkedList<JavaRDD<String>>(); queue.add(history_); JavaDStream<String> history_dstream = ssc.queueStream(queue); JavaPairDStream<String,ArrayList<String>> ...
Cómo escribir la salida de Spark Streaming en HDFS sin sobrescribir
Después de un procesamiento, tengo un DStream [String, ArrayList [String]], así que cuando lo escribo en hdfs usando saveAsTextFile y después de cada lote sobrescribe los datos, así que cómo escribir un nuevo resultado al agregarlo a resultados ...
Consumidor atrapado en reingresar
He leído otros hilos y he solucionado el problema utilizando una nueva ID de grupo, sin embargo, me gustaría entender qué podría causar esto. Tengo un tema con 16 particiones, configuré session.timeout.ms = 30000 y max.poll.interval.ms = ...
¿Es posible en Debezium configurar table_name => mapeo de temas kafka?
he leídohttp://debezium.io/docs/connectors/mysql/ [http://debezium.io/docs/connectors/mysql/]pero no pude encontrar ninguna información sobre si debezium se puede configurar para que los cambios de 2 (o más) tablas se puedan escribir en el mismo ...
¿Se puede proporcionar Kafka con LoginModule personalizado para admitir LDAP?
Kafka se puede configurar para usar varios mecanismos de autenticación: nombre de usuario / contraseña de texto sin formato, Kerberos o SSL. Los primeros 2 usan SASL, donde se requiere un archivo de configuración JAAS. Para el método de ...
Los trabajos de Connect consumer se eliminan al reiniciar el clúster
Estoy enfrentando el siguiente problema al cambiar algunas propiedades relacionadas con kafka y reiniciar el clúster. In kafka Consumer, there were 5 consumer jobs are running .Si realizamos algún cambio importante en la propiedad, y al ...
Apache Kafka Streams Materializing KTables a un tema parece lento
Estoy usando kafka stream y estoy tratando de materializar una tabla K en un tema. Funciona pero parece que se hace cada 30 segundos más o menos. ¿Cómo / cuándo Kafka Stream decide materializar el estado actual de una KTable en un tema? ¿Hay ...