# Kafka Data loss

**URL:** <https://forum.confluent.io/t/kafka-data-loss/10154>\
**Category:** Kafka Streams\
**Created:** [13 February 2024 10:33 UTC](https://forum.confluent.io/t/kafka-data-loss/10154 "2024-02-13T10:33:49Z")\
**Posts on this page:** 6\
**Page:** 1

<div class="post-metadata">

**Author:** ![harmeet](https://avatars.discourse-cdn.com/v4/letter/h/4af34b/32.png) [@harmeet](https://forum.confluent.io/u/harmeet)\
**Post date:** [13 February 2024 10:33 UTC](https://forum.confluent.io/t/kafka-data-loss/10154/1 "2024-02-13T10:33:50Z")

</div>

Hello,

We are facing issue in Kafka messages streaming if connectivity break down.  
Data is getting lost if connectivity break down or broker is not available.

---

<div class="post-metadata">

**Author:** ![mjsax](https://sea1.discourse-cdn.com/flex019/user_avatar/forum.confluent.io/mjsax/32/3113_2.png) [@mjsax](https://forum.confluent.io/u/mjsax)\
**Post date:** [15 February 2024 01:31 UTC](https://forum.confluent.io/t/kafka-data-loss/10154/2 "2024-02-15T01:31:15Z")

</div>

Is this a Kafka Streams app, or actually a producer app?

What’s your topic / client configs? With retries / timeout / replication / acks configured correctly, no data loss should happen. Also, what broker/client versions are you using (newer versions ship with different default configs than older version).

---

<div class="post-metadata">

**Author:** ![harmeet](https://avatars.discourse-cdn.com/v4/letter/h/4af34b/32.png) [@harmeet](https://forum.confluent.io/u/harmeet)\
**Post date:** [15 February 2024 08:21 UTC](https://forum.confluent.io/t/kafka-data-loss/10154/3 "2024-02-15T08:21:36Z")

</div>

we are using producer on one server ‘x’ and consumer on other server says ‘y’.We stopped kafka service on consumer ‘y’.We are sending data from x to y . Few messages are visible after starting kafka on ‘‘y’’ other messages or data is getting lost.  
We have added below properties as:  
if (rd\_kafka\_conf\_set(conf, “enable.idempotence”, “true”, errstr, sizeof(errstr)) != RD\_KAFKA\_CONF\_OK)  
{  
TRACE\_SHOW(errstr);  
}  
if (rd\_kafka\_conf\_set(conf, “message.send.max.retries”, “200”, errstr, sizeof(errstr)) != RD\_KAFKA\_CONF\_OK)  
{  
TRACE\_SHOW(errstr);  
}  
if (rd\_kafka\_conf\_set(conf, “retry-backoff-ms”, “2000”, errstr, sizeof(errstr)) != RD\_KAFKA\_CONF\_OK)  
{  
TRACE\_SHOW(errstr);  
}  
if (rd\_kafka\_conf\_set(conf, “delivery.timeout.ms”, “150000”, errstr, sizeof(errstr)) != RD\_KAFKA\_CONF\_OK)  
{  
TRACE\_SHOW(errstr);  
}  
if (rd\_kafka\_conf\_set(conf, “acks”, “all”, errstr, sizeof(errstr)) != RD\_KAFKA\_CONF\_OK)  
{  
TRACE\_SHOW(errstr);  
}  
if (rd\_kafka\_conf\_set(conf, “max.in.flight.requests.per.connection”, “1”, errstr, sizeof(errstr)) != RD\_KAFKA\_CONF\_OK)  
{  
TRACE\_SHOW(errstr);  
}

```
But getting errstr=No such configuration property: "delivery.timeout.ms" for each property.
Please suggest how can we reloved it.

```

---

<div class="post-metadata">

**Author:** ![harmeet](https://avatars.discourse-cdn.com/v4/letter/h/4af34b/32.png) [@harmeet](https://forum.confluent.io/u/harmeet)\
**Post date:** [15 February 2024 12:28 UTC](https://forum.confluent.io/t/kafka-data-loss/10154/4 "2024-02-15T12:28:51Z")

</div>

We have checked version with below api:  
rd\_kafka\_version\_str()  
kafka version:0.11.6  
How to check broker version can you please share command for this?

---

<div class="post-metadata">

**Author:** ![mjsax](https://sea1.discourse-cdn.com/flex019/user_avatar/forum.confluent.io/mjsax/32/3113_2.png) [@mjsax](https://forum.confluent.io/u/mjsax)\
**Post date:** [15 February 2024 20:50 UTC](https://forum.confluent.io/t/kafka-data-loss/10154/5 "2024-02-15T20:50:22Z")

</div>

So it’s not a Kafka Streams question.

Might be best to re-post in [Non-Java Clients - Confluent Community](https://forum.confluent.io/c/clients/non-java-clients/25)

And there is no `kafka version:0.11.6` – seems you are referring to your librdkafka version?

(Also Kafka 0.11. would be very old…)

> How to check broker version can you please share command for this?

Brokers don’t have an API to query their version AFAIK. If you are not running the brokers yourself, you would need to ask the team running the brokers what version they deployed.

---

<div class="post-metadata">

**Author:** ![harmeet](https://avatars.discourse-cdn.com/v4/letter/h/4af34b/32.png) [@harmeet](https://forum.confluent.io/u/harmeet)\
**Post date:** [16 February 2024 05:20 UTC](https://forum.confluent.io/t/kafka-data-loss/10154/6 "2024-02-16T05:20:27Z")

</div>

Then how to check kafka version plz suggest