This PR clears the optional fields FetchResponse::node_endpoints, PartitionData::preferred_read_replica and PartitionData::current_leader in the Fetch 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
FetchResponse::node_endpoints
,PartitionData::preferred_read_replica
andPartitionData::current_leader
in the Fetch 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 #1665