Resultados de la búsqueda a petición "apache-kafka"
Kafka políticas de retención
Suponga que tengo una configuración de Kafka de varios intermediarios (ejecutándose en el mismo host) con 3 intermediarios y 50 temas, cada uno de los cuales está configurado para tener 7 particiones y un factor de replicación de 3. Tengo 50 GB ...
¿Es una buena práctica realizar consultas de sincronización de base de datos o llamadas relajantes en trabajos de Kafka streams?
Utilizo transmisiones de Kafka para procesar datos en tiempo real, en las tareas de transmisiones de Kafka, necesito acceder a MySQL para consultar datos y llamar a otro servicio tranquilo. Todas las operaciones son sincrónicas. Me temo que ...
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 ...
Assert Kafka enviar trabajado
Estoy escribiendo una aplicación con Spring Boot, así que para escribir a Kafka hago: @Autowired private KafkaTemplate<String, String> kafkaTemplate; y luego dentro de mi método: kafkaTemplate.send(topic, data)Pero siento que solo estoy ...
¿Cómo probar un ConsumerAwareRebalanceListener?
Desarrollé un@KafkaListener que también está marcado con laConsumerAwareRebalanceListener interfaz, usando Spring Boot 2.0.6. Implementé elonPartitionsAssigned método, en el que rebobino el desplazamiento de una cantidad fija de tiempo, digamos ...
Cómo obtener el esquema del conector de origen Kafka basado en el nombre del conector
Estoy usando el conector Confluent JDBC Kafka para publicar mensajes en el tema. El conector de origen enviará datos al tema junto con el esquema en cada encuesta. Quiero recuperar este esquema. ¿Es posible? ¿Cómo? ¿Alguien puede sugerirme Mi ...
Kafka streams: Leer desde TODAS las particiones en cada instancia de una aplicación
Cuando se usa KTable, las transmisiones de Kafka no permiten que las instancias lean desde múltiples particiones de un tema en particular cuando la cantidad de instancias / consumidores es igual a la cantidad de particiones. Intenté lograr esto ...
Kafka Consumer no recibe datos cuando uno de los corredores está caído
Kafka Quickstart [https://kafka.apache.org/quickstart] Utilizando Kafka v2.1.0 en RHEL v6.9 Consumer no recibe datos cuando uno de los corredores de Kafka está caído. Pasos realizados: 1. Iniciar zookeeper 2. Inicie Kafka-Server0 (localhost: ...
org.springframework.context.ApplicationContextException: no se pudo iniciar bean 'org.springframework.kafka.config.internalKafkaListenerEndpointRegistry
Estoy desarrollandoSpring Boot + Apache Kafka + Apache Zookeeper ejemplo. Instalé / configuréApache Zookeeper and Apache Kafka en mi máquina de Windows local. Tomé una referencia del ...
Kafka consumidor no devuelve ningún evento
El consumidor de Scala kafka a continuación no devuelve ningún evento depoll llamada Sin embargo, el tema es correcto, y puedo ver los eventos que se envían al tema utilizando el consumidor de la ...