Page History
...
| Expand | ||||||
|---|---|---|---|---|---|---|
| ||||||
|
2.솔류션내 라이브러리 설치(.net)
KAFKA 사용하기
| Code Block | ||||||
|---|---|---|---|---|---|---|
| ||||||
using KafkaNet;
var options = new KafkaOptions(new Uri("http://localhost:9092"), new Uri("http://localhost:9092"));
var router = new BrokerRouter(options);
var client = new Producer(router);
client.SendMessageAsync("test", new[] { new Message("hello world") }).Wait();
|
...