Alexander Stepanov created KAFKA-6909: -----------------------------------------
Summary: Message Accumulation in case of no connection to Kafka Key: KAFKA-6909 URL: https://issues.apache.org/jira/browse/KAFKA-6909 Project: Kafka Issue Type: Improvement Components: clients Reporter: Alexander Stepanov Simple situation: 0) We have service A which works with Kafka as client 1) No connection to Kafka 2) Service A accumulates messages for sending to Kafka, but still no connection to Kafka 3) Then service A is crashed for some reason, for example, OOM or just server is dead 4) How to recover accumulated messages? I think - it will be good to have some general code basement to persist service's outgoing messages to Kafka. For example, if service A is crashed, it can fetch messages from some local storage on startup and resend it to Kafka. -- This message was sent by Atlassian JIRA (v7.6.3#76005)