search

shotover / shotover-proxy

L7 data-layer proxy
https://docs.shotover.io
Apache License 2.0
84 stars 16 forks source link

KafkaSinkCluster - rewrite produce responses to not refer to real brokers #1664

Closed rukai closed 3 months ago

rukai commented 3 months ago

rewrite ProduceResponse::node_endpoints and PartitionProduceResponse::current_leader to avoid pointing at the real kafka broker. The logic can go in KafkaSinkCluster::process_responses. We should be able to just clear these values from the produce response and then call Message::invalidate_cache()

There are some extra details in: https://github.com/shotover/shotover-proxy/issues/1665