| 일 | 월 | 화 | 수 | 목 | 금 | 토 |
|---|---|---|---|---|---|---|
| 1 | 2 | 3 | 4 | 5 | ||
| 6 | 7 | 8 | 9 | 10 | 11 | 12 |
| 13 | 14 | 15 | 16 | 17 | 18 | 19 |
| 20 | 21 | 22 | 23 | 24 | 25 | 26 |
| 27 | 28 | 29 | 30 | 31 |
- eck
- docker
- kafka-connect
- Consumer
- go
- ElasticSearch
- kafka broker
- Kafka Connect
- Kubernetes
- Elk
- Kafka
- create topic
- broker
- topic
- consumer group
- gin
- loadbalance
- Produce
- Golang
- minikube
- http
- k8s
- Message
- Helm
- gortsplib
- gorm
- tls disable
- 쿠버네티스
- go test
- kibana
- Today
- Total
목록create topic (2)
개발자의 개발괴발
[T.S] local에서 k8s의 broker에 접속이 안될때 2
이전의 설정으로 잘 되는줄 알았는데 잘 되지 않았다.이전 글에선 LoadBalancer type으로 동작을 시켰는데 이번엔 nodePort type으로 동작시켰다. 아래 명령어를 통해 얻은 values.yaml 파일을 다시 변경했다.helm show values bitnami/kafka > values.yaml전체 변경사항을 보여주자면listeners: client: containerPort: 9092 protocol: PLAINTEXT ## 여기 변경 name: CLIENT sslClientAuth: "" controller: name: CONTROLLER containerPort: 9093 protocol: PLAINTEXT ## 여기 변경 sslCl..
토픽을 만들기 위해선 Admin client를 이용해야 한다.admin, err := kafka.NewAdminClient(&kafka.ConfigMap{"bootstrap.servers": "localhost:9092"})위와 같이 새로운 admin client를 생성한다.config에는 bootstrap.servers 항목만 추가해준다.localhost:9092로 포트포워딩 해놓았으니 bootstrap.servers를 localhost:9092로 설정한다. 로컬에서 kafka client를 실행시켜 myTopic이라는 topic을 하나 생성해보자.이때 토픽의 파티션은 20개, replication factor는 3개로 하자.(replication factor는 broker의 수를 넘을 수 없음)아래 ..