This PR clears the optional fields ProduceResponse::node_endpoints and PartitionProduceResponse::current_leader in the Produce response processed by the KafkaSinkCluster process_responses() function . This is to avoid passing these values to the client which will make the client try to bypass shotover and connect to Kafka brokers directly.
This PR clears the optional fields
ProduceResponse::node_endpoints
andPartitionProduceResponse::current_leader
in the Produce response processed by the KafkaSinkClusterprocess_responses()
function . This is to avoid passing these values to the client which will make the client try to bypass shotover and connect to Kafka brokers directly.Closes https://github.com/shotover/shotover-proxy/issues/1664