닷넷 4.8에서 카프카 컨슈머 구성하기 (Kafka Consumer)

1. NuGet 패키지 설치:
프로젝트에 Confluent.Kafka NuGet 패키지를 추가합니다. 이 패키지는 Kafka 클라이언트를 제어하는 데 사용

2. Kafka 클라이언트 구성:
ProducerConfig 및 ConsumerConfig 클래스를 사용하여 Kafka 클라이언트를 구성. 여기에는 Kafka 브로커, 토픽, 그룹 ID 등의 설정이 포함된다.

 

 

샘플소스

using Confluent.Kafka;
using System;

class Program
{
    static void Main(string[] args)
    {
        // Kafka 클라이언트 설정
        var producerConfig = new ProducerConfig
        {
            BootstrapServers = "localhost:9092", // Kafka 브로커 주소
            ClientId = "sample-producer"
        };

        // Kafka Producer 생성
        using (var producer = new ProducerBuilder<Null, string>(producerConfig).Build())
        {
            // 메시지 전송
            producer.Produce("sample-topic", new Message<Null, string> { Value = "Hello Kafka" });
        }

        // Kafka Consumer 설정
        var consumerConfig = new ConsumerConfig
        {
            BootstrapServers = "localhost:9092",
            GroupId = "sample-consumer-group",
            AutoOffsetReset = AutoOffsetReset.Earliest
        };

        // Kafka Consumer 생성
        using (var consumer = new ConsumerBuilder<Ignore, string>(consumerConfig).Build())
        {
            // 토픽 구독
            consumer.Subscribe("sample-topic");

            // 메시지 수신 루프
            while (true)
            {
                var consumeResult = consumer.Consume();
                Console.WriteLine($"Received: {consumeResult.Message.Value}");
            }
        }
    }
}

 

해당부분은 컨슈머에 대한 구성으로

Kafka 클러스터 및 브로커가 미리 구성되어 있어야 함.