1
resposta

Erro ao conectar Java ao Kafka

Boa noite pessoal!!

Estou tendo dificuldades para conectar o meu producer em Java ao Kafka, sempre recebo o seguinte erro:

org.apache.kafka.common.errors.TimeoutException: Expiring 1 record(s) for ECCOMMERCE_NEW_ORDER-0:120009 ms has passed since batch creation
Exception in thread "main" java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.TimeoutException: Expiring 1 record(s) for ECCOMMERCE_NEW_ORDER-0:120009 ms has passed since batch creation
    at org.apache.kafka.clients.producer.internals.FutureRecordMetadata.valueOrError(FutureRecordMetadata.java:97)
    at org.apache.kafka.clients.producer.internals.FutureRecordMetadata.get(FutureRecordMetadata.java:65)
    at org.apache.kafka.clients.producer.internals.FutureRecordMetadata.get(FutureRecordMetadata.java:30)
    at br.com.alura.eccommerce.NewOrderMain.main(NewOrderMain.java:22)
Caused by: org.apache.kafka.common.errors.TimeoutException: Expiring 1 record(s) for ECCOMMERCE_NEW_ORDER-0:120009 ms has passed since batch creation

ja reiniciei a maquina e continuei recebendo o mesmo erro.

1 resposta

Boa noite Ana.

Isso normalmente ocorre quando a velocidade do producer é muito rapida.

Dá uma olhada como está a configuração do seu topico referente ao numero de partiçoes.

Por exemplo. Se seu topico tiver 2 partições e seu producer estiver produzindo um numero maior que isso... começa a gerar este erro.

Altera a configuração do topico para aumentar o numero de partições ou vc pode recriado com um numero maior

Aqui neste link tem umas soluçoes que podem ajudar

https://localcoder.org/kafka-producer-error-expiring-10-records-for-topicxxxxxx-6686-ms-has-passed