Kafka Topic 생성 및 Producer/Consumer 테스트

topic 생성

# broker 서버 접속
# topic 목록 확인
kafka-topics --bootstrap-server localhost:9092 --list

# topic 생성
kafka-topics --bootstrap-server localhost:9092 --create --topic test --partitions 1

# topic 확인
kafka-topics --bootstrap-server localhost:9092 --describe --topic test

producer/consumer 테스트

# producer 생성
kafka-console-producer --broker-list localhost:9092 --topic test
> 여기에 전달할 내용 입력

# consumer 생성
kafka-console-consumer --bootstrap-server localhost:9092 --topic test --from-beginning

clubser id 및 topic 목록 조회

curl -XGET "http://localhost:8082/v3/clusters"

topic 생성

curl -XPOST "http://localhost:8082/v3/clusters/<cluster-id>/topics" -H "Content-Type: application/json" -d '{
  "topic_name": "my-topic",
  "partitions_count": 3,
  "replication_factor": 1,
  "configs": [{"name": "cleanup.policy", "value": "delete"}]
}'

topic 데이터 입력

# type이 없으면 400에러 발생
curl -XPOST "http://localhost:8082/v3/clusters/<cluster-id>/topics/my-topic/records" -H "Content-Type: application/json" -d '{
   "value": {
      "type": "STRING",
      "data": "Hello Kafka!"
    }
  }'