kafka-protocol-rs
kafka-protocol-rs copied to clipboard
tychedelia
Rust Kafka protocol
Thoughts on adding such a method? Similar interface to `::encode`, but would calculate the encoding size based on the given params.
There's a lot of messages related to Raft that are unlikely to ever be useful to someone using this crate. We should have a mechanism to filter out messages that...
As far as I can tell, there is no reason for the builders to be fallible. The framework being used has this pattern in place to support things like validation...
Overall I've found the generated message types seem quite easy to work with so far - with the exception of `StrBytes` wrappers like `TopicName`. From what I can tell, the...
I'm interested in utilizing this crate but I'm curious if there are any other existing crates building out higher-level client functionality? It would be awesome if there were some examples...
This would add a next level of performance to parsing incoming Kafka requests. The main idea: - Request payloads would be parsed / validate in a way which is not...
Generating an `Encodable` impl on the `ResponseKind` enum would be a nice ergonomics win. All it would do is just match over the response kind, and then call encode on...
I want to reimplement certain encoders/decoders to improve performance by skipping parts I dont need. It would be nice to be able to reuse some Encoder/Decoder implementations on types like...
In [kafkas](https://github.com/iamazy/kafkas), when I consume records which produced from [native kafka client](https://github.com/apache/kafka/tree/trunk/clients), it always got `Decode Error`. but everything is OK when I use `Producer` in [kafkas](https://github.com/iamazy/kafkas). Currently I ignore...