Message Broker Rust SDK examples.

let broker = InMemoryBroker::with_start_time(Timestamp::from_unix_millis(10_000));
let mut client = NativeClient::new(broker, ClientConfig::new("telemetry-producer"))?;

client.create_stream(
    "telemetry",
    DurabilityMode::LocalDisk,
    RetentionPolicy::default(),
)?;

let first = client.publish(
    PublishMessage::new(
        "telemetry",
        Timestamp::from_unix_millis(1_700_000_000_000),
        b"reading-1".to_vec(),
    )
    .with_message_id("reading-1")
    .with_key(b"machine-17".to_vec()),
)?;

let batch = client.batch_publish(vec![
    PublishMessage::new(
        "telemetry",
        Timestamp::from_unix_millis(1_700_000_000_001),
        b"reading-2".to_vec(),
    )
    .with_message_id("reading-2"),
    PublishMessage::new(
        "telemetry",
        Timestamp::from_unix_millis(1_700_000_000_002),
        b"reading-3".to_vec(),
    )
    .with_message_id("reading-3"),
])?;

let replay = client.subscribe_replay("telemetry", "analytics", StartPosition::Earliest)?;
let fetched = client.fetch(&replay, 10)?;

client.commit_cursor("telemetry", "analytics", "processed", fetched.next_offset)?;