카프카 관련 & ssh터널링

컨슈머삭제

bin/kafka-consumer-groups.sh —bootstrap-server 서버:9092 —delete —group 그룹명

토픽삭제

bin/kafka-topics.sh --delete --zookeeper 서버:2181 --topic 토픽명
또는
bin/kafka-topics.sh --delete --bootstrap-server 서버:9092 --topic 토픽명

카프카 접속 내부

bin/kafka-console-producer.sh --broker-list 서버:9092 --topic 토픽명

카프카 접속 외부

bin/kafka-console-consumer.bat --bootstrap-server 접속할서버:접속할포트 --topic 토픽명

#토픽 전체 데이터 보기
bin/kafka-console-consumer.bat --bootstrap-server 접속할서버:접속할포트 --topic 토픽명 --from-beginning

토픽생성

bin/kafka-topics.sh --create --topic 토픽명 --bootstrap-server 서버:9092 --partitions 1 --replication-factor 1 --timeout 30000

터널링

ssh -L 로컬포트:실제서버:실제서버에서사용할포트  root@접속할서버

#백그라운드에서
ssh -L 로컬포트:실제서버:실제서버에서사용할포트  root@접속할서버 -N -f

터널링 config 설정

sudo vi /etc/ssh/sshd_config

AllowTcpForwarding yes
GatewayPorts yes