kafka-threadpool 1.0.12

An async rust threadpool for publishing messages to kafka using SSL (mTLS) or PLAINTEXT protocols.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48

//! helper for building a supported
//! [`KafkaPublishMessage`](crate::api::kafka_publish_message::KafkaPublishMessage)
//! message.
//!
use std::collections::HashMap;

use crate::api::kafka_publish_message::KafkaPublishMessage;
use crate::api::kafka_publish_message_type::KafkaPublishMessageType;

/// build_kafka_publish_message
///
/// Create a publishable kafka message based off the supported
/// arguments
///
/// # Arguments
///
/// * `msg_type` - request type of message [`KafkaPublishMessageType`]
/// * `topic` - kafka topic to publish the message into
/// * `key` - kafka partition key
/// * `headers` - optional - headers for the kafka message
/// * `payload` - data within the kafka message
///
/// # Examples
///
/// ```rust
/// use std::collections::HashMap;
/// use kafka_threadpool::api::build_kafka_publish_message::build_kafka_publish_message;
/// use kafka_threadpool::api::kafka_publish_message_type::KafkaPublishMessageType;
/// let mut hmap: HashMap<String, String> = HashMap::new();
/// hmap.insert("header 1".to_string(), "value 1".to_string());
/// let new_msg: KafkaPublishMessage = build_kafka_publish_message(
///     KafkaPublishMessageType::Data,
///     "testing",
///     "custom-partition-key",
///     Some(hmap),
///     "testing build_kafka_publish_message");
/// println!("created new kafka_publish_message:\n{new_msg}");
/// ```
///
pub fn build_kafka_publish_message(
    msg_type: KafkaPublishMessageType,
    topic: &str,
    key: &str,
    headers: Option<HashMap<String, String>>,
    payload: &str,
) -> KafkaPublishMessage {
    KafkaPublishMessage::new_from(msg_type, topic, key, headers, payload)
}