shotover/shotover-proxy

KafkaSinkCluster - rewrite produce responses to not refer to real brokers

Closed this issue · 0 comments

rukai commented

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: #1665