search

tychedelia / kafka-protocol-rs

Rust Kafka protocol
Apache License 2.0
63 stars 23 forks source link

fix lz4 compression #59

Closed pdeva closed 4 months ago

pdeva commented 4 months ago

kafka java client doesnt support depedent blocks. without the fix in this PR, the kafka java client will throw an exception.

https://github.com/a0x8o/kafka/blob/54eff6af115ee647f60129f2ce6a044cb17215d0/clients/src/main/java/org/apache/kafka/common/record/KafkaLZ4BlockOutputStream.java#L344

tychedelia commented 4 months ago

We might want to document our compatibility here somewhere. The library is theoretically agnostic to client/server but in practice I imagine most people interact with "real" Kafka.

tychedelia commented 4 months ago

Looks like you have some build failures @pdeva

tychedelia commented 4 months ago

@pdeva https://github.com/tychedelia/kafka-protocol-rs/releases/tag/0.10.1