Estoy usando la versión 1.3.0 del cliente Confluent.Kafka .NET. Estoy siguiendo los documentos : var consumerConfig = new ConsumerConfig { BootstrapServers = "server1, server2", AutoOffsetReset = AutoOffsetReset.Earliest, EnableAutoCommit = true, EnableAutoOffsetStore = false, GroupId =...
Continuamente recibo FETCH_SESSION_ID_NOT_FOUND. No estoy seguro de por qué está sucediendo. ¿Alguien puede complacerme aquí cuál es el problema y cuál será el impacto en los consumidores y los corredores? Registro del servidor Kafka: INFO [2019-10-18 12:09:00,709] [ReplicaFetcherThread-1-8][]...
Tengo una aplicación simple, con dos funciones, una para escuchar el tema y otra para el punto final web. Quiero crear la transmisión de eventos del lado del servidor (SSE), es decir, texto / evento-transmisión, para que en el extremo del cliente pueda escucharlo usando EventSource. Tengo el...
Estaba revisando el documento que entendí que podemos lograr exactamente una sola transacción con la habilitación idempotence=true idempotencia: el productor idempotente habilita exactamente una vez para un productor contra un solo tema. Básicamente, cada mensaje enviado tiene garantías más...
Al definir una topología en flujos kafka, se puede agregar una tienda de estado global. Necesitará un tema fuente, así como a ProcessorSupplier. El procesador recibe registros y podría transformarlos teóricamente antes de agregarlos a la tienda. Pero en caso de restauración, los registros se...