Skip to content

Commit

Permalink
Update migration.md
Browse files Browse the repository at this point in the history
  • Loading branch information
toelo3 authored Dec 10, 2024

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature.
1 parent ca638e4 commit 80a879e
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions dsh_sdk/migration.md
Original file line number Diff line number Diff line change
@@ -9,8 +9,8 @@
- [Current SDK usage](#current-sdk-usage)
- [Expected SDK usage](#expected-sdk-usage)
- [Migration process](#migration-process)
- [v0.5.0 (expected release date: 2024-01-01)](#v050-expected-release-date-2024-01-01)
- [v0.6.0 (expected release date: 2024-02-01)](#v060-expected-release-date-2024-02-01)
- [v0.5.0 (expected release date: 2025-01-01)](#v050-expected-release-date-2025-01-01)
- [v0.6.0 (expected release date: 2025-02-01)](#v060-expected-release-date-2025-02-01)

## Why restructuring?
The SDK was initially built around the Kafka protocol and easily connect to DSH. Meanwhile, we also want to support other protocols (e.g. MQTT and Http) and add extra utilities to the SDK to make it more easier for developer to work with DSH.
@@ -93,7 +93,7 @@ use rdkafka::ClientConfig; // Import RDKafka directly
use rdkafka::consumer::{Consumer, StreamConsumer}; // Import RDKafka directly

fn main() -> Result<(), Box<dyn std::error::Error>>{
let consumer: StreamConsumer = let consumer: StreamConsumer = ClientConfig::new()
let consumer: StreamConsumer = ClientConfig::new()
.dsh_config() // Comes from the DshKafkaConfig trait
.create();?;
Ok(())

0 comments on commit 80a879e

Please sign in to comment.