Resultados de la búsqueda a petición "kafka-consumer-api"
¿Cómo funciona kafka consumer auto commit?
Estoy leyendoéste [https://www.safaribooksonline.com/library/view/kafka-the-definitive/9781491936153/ch04.html#callout_kafka_consumers__reading_data_from_kafka_CO2-1] : Confirmación automática La forma más fácil de confirmar las compensaciones ...
Código de error del consumidor de alto nivel de Kafka = 15
Cuando se trata de consumir desde Kafka usando el consumidor de alto nivel (usando un grupo de consumidores completamente nuevo), el consumidor nunca comienza a funcionar. Cuando cambio el nivel de registro a depuración, puedo ver las dos líneas ...
Cómo configurar temas de Kafka para que las bases de datos como RDMS y gráficas puedan consumir un esquema de entidad interconectada en forma de eventos
Tengo un caso donde tengoInformation objetos que contienenElement objetos. Si guardo unInformation objetará que intentará encontrar preexistenteElement objetos basados en un campo de valor único; de lo contrario, insértelos.Information objetos ...
Filtrado de flujos de Kafka: ¿corredor o consumidor?
Estoy mirando las corrientes de kafka. Quiero filtrar mi flujo, usando un filtro con muy baja selectividad (uno en unos pocos miles). Estaba mirando este ...
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 ...
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 = ...
Solicitar mensajes entre dos marcas de tiempo de Kafka
¿Es posible consumir mensajes de Kafka en función de un período de tiempo en el que se ingirieron los mensajes? Ejemplo: Quiero que todos los mensajes se ingieran a un tema entre 0900-1000 hoy (y ahora son 1200). Si solo hay una manera de ...
Consumidor de kafka de primavera, ¿busca compensación en tiempo de ejecución?
Estoy usando el KafkaMessageListenerContainer para consumir del tema kafka, tengo una lógica de aplicación para procesar cada registro que también depende de otros micro servicios. Ahora estoy confirmando manualmente el desplazamiento después de ...
Obteniendo el último mensaje enviado a un tema kafka
Soy nuevo en Kafka y estoy trabajando en un prototipo para conectar un servicio de transmisión patentado a Kafka. Estoy buscando obtener la clave del último mensaje enviado sobre un tema, ya que nuestro consumidor interno de transmisiones debe ...
Algoritmo de reequilibrio del consumidor de Kafka
¿Puede alguien decirme cuál es el algoritmo de reequilibrio para los consumidores de Kafka? Me gustaría entender cómo el recuento de particiones y los hilos de consumo afectan esto. Gracias,