주키퍼 서버 실행

zookeeper-server-start.bat ../../config/zookeeper.properties

 

카프카 서버 실행

kafka-server-start.bat ../../config/server.properties

 

토픽 생성 2.2 버전 이상

kafka-topics.bat --create --topic ngm-topic --bootstrap-server localhost:9092 --replication-factor 1 --partitions 4

 

토픽 리스트 확인

kafka-topics.bat --list --bootstrap-server localhost:9092

 

토픽 생성 2.2 버전 미만

kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic ngm-topic

 

토픽 리스트 확인

kafka-topics.bat --list --zookeeper localhost:2181

 

C#에서 ConsumerConfig를 생성하고, consumer.Subscribe에 위에서 생성한 토픽(ngm-topic)을 적어줘야 합니다.

var config = new ConsumerConfig
{
    BootstrapServers = "localhost:9092",
    GroupId = "mspc",
    AutoOffsetReset = AutoOffsetReset.Earliest
};

using (var consumer = new ConsumerBuilder<Ignore, string>(config).Build())
{
    consumer.Subscribe(new string[] { "ngm-topic" });

    while (!_kafkaCancelled)
    {
        var consumeResult = consumer.Consume(100);

        if (consumeResult == null)
            continue;

        var msg = consumeResult.Message;

        Console.WriteLine(msg.Value);
        log.Info(msg.Value);

        ThreadPool.QueueUserWorkItem(ExecuteThread);

        semaphore.Set();
    }
    consumer.Close();
}

 

Producer는 아래와 같이 메세지를 보냅니다.

var config = new ProducerConfig
{
    BootstrapServers = "localhost:9092"
};


using (var producer = new ProducerBuilder<Null, string>(config).Build())
{
    producer.Produce("ngm-topic", new Message<Null, string> { Value = "Welcome to NGMsoftware!" });
}

 

개발자에게 후원하기

 

추천, 구독, 홍보 꼭~ 부탁드립니다.

여러분의 후원이 빠른 귀농을 가능하게 해줍니다~ 답답한 도시를 벗어나 귀농하고 싶은 개발자~

감사합니다~

추천0 비추천0