Struct KafkaResource 

pub struct KafkaResource {
    pub broker: String,
    pub schema_registry_url: String,
    pub topic: String,
    /* private fields */
}

Kafka resource manager

Fields

broker: String

Kafka broker address

schema_registry_url: String

Schema registry URL

topic: String

Name of the isolated topic

Implementations

impl KafkaResource

pub async fn new( broker: &str, schema_registry_url: &str, topic: &str, ) -> Result<Self>

Create a new Kafka resource with an isolated topic

pub async fn register_schema(&self, schema: &str) -> Result<u32>

Register an Avro schema for the topic

pub async fn produce_json_records<T: Serialize>( &self, records: &[T], ) -> Result<()>

Produce JSON records to the topic (without schema registry)

pub async fn produce_avro_records<T: Serialize>( &self, records: &[T], ) -> Result<()>

Produce Avro records to the topic (with schema registry) Uses dbz.op=‘c’ (create/insert) header by default

pub async fn produce_avro_records_with_op<T: Serialize>( &self, records: &[T], op: &str, ) -> Result<()>

Produce Avro records with a specific debezium operation type op: “c” = create/insert, “u” = update, “d” = delete

pub async fn produce_raw(&self, records: &[Vec<u8>]) -> Result<()>

Produce raw bytes to the topic

pub async fn inspect_topic_messages( broker: &str, schema_registry_url: &str, topic: &str, max_messages: usize, max_show: usize, ) -> Result<(Vec<(i64, String, String)>, Option<i64>)>

Inspect messages in an existing topic without creating it Returns (messages, highest_offset) where messages are (offset, key, id_string) tuples

pub async fn cleanup(&self) -> Result<()>

Delete the topic (can be called explicitly if needed)

Trait Implementations

impl Drop for KafkaResource

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.