мс прошло с момента создания партии плюс время задержки - PullRequest
Новая
       9

мс прошло с момента создания партии плюс время задержки

0 голосов
/ 03 февраля 2020

Я использую SQL 2.4.1v в качестве потребителя и Spring boot в качестве производителя для моей kafka topi c. Когда я пытаюсь вставить записи в topi c, я получаю следующее сообщение об ошибке: 

WARN 12044 --- [ad | producer-1] o.a.k.clients.producer.internals.Sender  : [Producer clientId=producer-1] Got error produce response with correlation id 4457 on topic-partition TRANS_INBOUND-20, retrying (0 attempts left). Error: NETWORK_EXCEPTION
WARN 12044 --- [ad | producer-1] o.a.k.clients.producer.internals.Sender  : [Producer clientId=producer-1] Received invalid metadata error in produce request on partition TRANS_INBOUND-20 due to org.apache.kafka.common.errors.NetworkException: The server disconnected before a response was received.. Going to request metadata update now
ERROR 12044 --- [ad | producer-1] o.s.k.support.LoggingProducerListener    : Exception thrown when sending a message with key='1-356194-2018-01-02-STATUS' and payload='com.TransRecord@48323556' to topic TRANS_INBOUND:

org.apache.kafka.common.errors.TimeoutException: Expiring 1 record(s) for TRANS_INBOUND-82: 501 ms has passed since batch creation plus linger time

Ниже приведены настройки моего производителя: 

    acks: 1
    retries: 1
    batchSize: 100
    lingerMs: 5
    bufferMemory: 33554432 
    requestTimeoutMs: 600
    autoOffsetReset: latest
    enableAutoCommit: false
    reconnectBackoffMaxMs: 1000
    reconnectBackoffMs: 50
    retryBackoffMs: 100

У меня уже есть пробовал со многими комбинациями batchSize, lingerMs и requestTimeoutMs, ничего не работает. Я все еще вижу вышеупомянутые ошибки довольно часто. Любая помощь в том, что здесь не так и как решить эту проблему.

...