tisonkun / kafka-api

Generic abstractions for Kafka API.
https://crates.io/crates/kafka-api
Apache License 2.0
14 stars 2 forks source link

Heartbeat support #9

Closed aovestdipaperino closed 2 months ago

aovestdipaperino commented 2 months ago

I think, still not 100% positive, this is required for the Spring Boot client; if I send a default response my Spring Boot app happily consumes the messages. Request code is here: https://github.com/aovestdipaperino/kafka-api/blob/expiration/kafka-api/src/schemata/heartbeat_request.rs Response code here: https://github.com/aovestdipaperino/kafka-api/blob/expiration/kafka-api/src/schemata/heartbeat_response.rs

tisonkun commented 2 months ago

Looks reasonable. Let me take a look in this week.

tisonkun commented 2 months ago

0.3.1 is out with this support