[Kafka] .Net으로 Consumer 개발

개요

• Spark -> Kafka -> Unity
• Spark(Producer)에서 보낸 데이터를 Broekr를 통해 Unity(Consumer)에서 메세지 큐를 받아야함
  

Set Up

• 패키지 관리자 콘솔 열기
  

Install

• Kafka
  • Dotnet Json
    Install-Package Newtonsoft.Json
  • Kafka Dotnet API
    Install-Package Confluent.Kafka -Version 1.8.2
    

코드

• Consumer

  • URL

  • Connection

    • GroupID : Consumer 그룹 아이디 설정
    • BootstrapServers : broker 리스트
    • AutoOffsetReset : 오프셋
      

  • Subscribe

    • 구독할 토픽 이름 설정
      

결과

URL

Walker