sander/kafka-blog
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

shorter

Browse source
This commit is contained in:
Shautvast 2024-11-20 15:23:42 +01:00
parent 83000e8b41
commit f021e99aae
1 changed files with 2 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
rust/src/main.rs
View file

@ -13,13 +13,10 @@ async fn main() -> anyhow::Result<()> {
"bootstrap.servers", "bootstrap.servers",
"localhost:39092,localhost:39093,localhost:39094", "localhost:39092,localhost:39093,localhost:39094",
) )
.create() .create()?;
.expect("Consumer creation error");
let avro_decoder = AvroDecoder::new(SrSettings::new("http://localhost:8081".into())); let avro_decoder = AvroDecoder::new(SrSettings::new("http://localhost:8081".into()));
consumer consumer.subscribe(&["rustonomicon"])?;
.subscribe(&["rustonomicon"])
.expect("Can't subscribe to specific topics");
while let Ok(message) = consumer.recv().await { while let Ok(message) = consumer.recv().await {
let value_result = avro_decoder.decode(message.payload()).await?.value; let value_result = avro_decoder.decode(message.payload()).await?.value;