如何在Rust中建立与kafka服务器的连接

[dependencies]
kafka-rust = "0.13.0"

use kafka_rust::client::{KafkaClient, KafkaClientConfig};

let mut client_config = KafkaClientConfig::new();
client_config.set("bootstrap.servers", "kafka_server:9092");

let kafka_client = KafkaClient::new(client_config);

kafka_client.connect().expect("Failed to connect to Kafka server");

let topic = "my_topic";
let partition = 0;
let message = "Hello Kafka!";

kafka_client.send_message(topic, partition, message.as_bytes()).expect("Failed to send message");