Estou recebendo FETCH_SESSION_ID_NOT_FOUND continuamente. Não sei por que isso está acontecendo. Alguém pode me agradar aqui qual é o problema e qual será o impacto nos consumidores e corretores. Log do servidor Kafka: INFO [2019-10-18 12:09:00,709] [ReplicaFetcherThread-1-8][]...
Eu tenho um aplicativo simples, com duas funções, uma para ouvir o tópico e outra para o endpoint da web. Desejo criar SSE (fluxo de eventos do lado do servidor), ou seja, texto / fluxo de eventos, para que no cliente final possa ouvi-lo usando EventSource. Eu tenho o seguinte código por enquanto,...
Eu estava analisando o que entendi que podemos conseguir com uma única transação, permitindo idempotence=true idempotência: o produtor Idempotent ativa exatamente uma vez um produtor em um único tópico. Basicamente, cada envio de mensagem tem garantias mais fortes e não será duplicado caso...
Ao definir uma topologia em fluxos kafka, um armazenamento de estado global pode ser adicionado. Ele precisará de um tópico de origem e também de um ProcessorSupplier. O processador recebe registros e pode teoricamente transformá-los antes de adicioná-los à loja. Porém, em caso de restauração, os...