- Notifications
You must be signed in to change notification settings - Fork6
snmslavk/kafka-net-core
Folders and files
| Name | Name | Last commit message | Last commit date | |
|---|---|---|---|---|
Repository files navigation
This is the net core versions of the librarykafka-net
Use .NET CLI
dotnet add package kafka-net-core --version 1.0.2
varoptions=newKafkaOptions(newUri("http://localhost:9092"));varrouter=newBrokerRouter(options);using(Producerclient=newProducer(router)){client.SendMessageAsync("test_topic",new[]{newMessage("hello world")}).Wait();}
varoptions=newKafkaOptions(newUri("http://localhost:9092"));varrouter=newBrokerRouter(options);using(varconsumer=newConsumer(newConsumerOptions("test_topic",router))){// Consume returns a blocking IEnumerable (ie: never ending stream)foreach(varmessageinconsumer.Consume()){Console.WriteLine("Response: P{0},O{1} : {2}",message.Meta.PartitionId,message.Meta.Offset,message.Value);}}
About
kafka .net core library
Topics
Resources
License
Code of conduct
Uh oh!
There was an error while loading.Please reload this page.
Stars
Watchers
Forks
Releases
No releases published
Packages0
No packages published
Uh oh!
There was an error while loading.Please reload this page.