kafka topic 생성/조회 in python

지난 포스팅에서 구성한 AWS MSK . 즉 카프카 클러스터에 토픽 생성 및 조회를 python 으로 작성해보겠습니다. 우선 AWS MSK는 public endpoint를 제공하지 않습니다. 즉 동일 vpc 내에서만 접근 가능하기에 동일 vpc 내의 EC2 인스턴스를 하나 만든 후 그곳에 python, kafka 라이브러리 등을 설치해서 접근하겠습니다. 우선 python을 설치합니다. 저는 jupyter notebook 으로 코드 작성을 할 예정이므로 anaconda 를 이용해서 한방에 설치를 했습니다. ubuntu@ip-172-31-6-168:~$ wget https://repo.anaconda.com/archive/Anaconda3-2020.07-Linux-x86_64.sh --2020-08-22 22:36:44-- https://repo.anaconda.com/archive/Anaconda3-2020.07-Linux-x86_64.sh Resolving repo.anaconda....

원문링크 : kafka topic 생성/조회 in python