태그 글목록: kafka

How to install apache kafka on ubuntu 14.10

카프카 설치

## http://kafka.apache.org/documentation.html#quickstart
# 1. wget 으로 다운로드 카프카. 경로는 홈피에서 최신판으로
wget http://mirror.apache-kr.org/kafka/0.8.1.1/kafka_2.9.2-0.8.1.1.tgz

# 2. 압축을 풀고 이동하자 ~
tar -xzf kafka_2.9.2-0.8.1.1.tgz
cd kafka_2.9.2-0.8.1.1

# 3. java설치
## sudo apt-get purge openjdk* ##openjdk 삭제할경우
sudo add-apt-repository ppa:webupd8team/java
sudo apt-get update
sudo apt-get install oracle-java8-installer
##화면에 그림같은거 나오면 화살표로 움직이고 스페이스로 선택하면됨

# 4. 주키퍼를 시작하자
## 카프카는 주키퍼를 사용합니다.
## 만약, 주키퍼를 사용하지 않고 있다면 일단 시작 해야합니다.
## 빠르고 단순한 단일노드의 주키퍼 인스턴스를 기동할수 있는
## 편리한 스크립트를 아래처럼 사용할수있습니다.
bin/zookeeper-server-start.sh config/zookeeper.properties

# 5. 이제 드디어 카프카를 시작하자
bin/kafka-server-start.sh config/server.properties

# 6. 토픽 생성
## test 라는 이름의 토픽을 싱글파티션과 싱글레플리카로 만들어 봅시다
bin/kafka-topics.sh –create –zookeeper localhost:2181 –replication-factor 1 –partitions 1 –topic test

## 자이제 우리는 아래 명령을 사용하여 선언된 토픽을 확인 할수 있습니다.
bin/kafka-topics.sh –list –zookeeper localhost:2181

## 매뉴얼로 토픽을 만드는 대신에
## 특정 토픽에 퍼블리쉬 할때 해당토픽이 없는경우
## 브로커에서 자동으로 토픽을 생성하도록 설정할수 있습니다.

# 7. 프로듀서를 만들어 보자
bin/kafka-console-producer.sh –broker-list localhost:9092 –topic test

##위와같이 프로듀서를 열어 두고 엔터를 친뒤 아무 텍스트나 쳐 넣어 보자

# 8. 컨슈머(수신측)를 만들어 보자.
bin/kafka-console-consumer.sh –zookeeper localhost:2181 –topic test –from-beginning

## 그럼 아마 데이터를 만나보실수 있을꺼에용 ㅋ

  • Facebook
  • Google Plus
  • Twitter
  • LinkedIn
  • Pinterest
  • Tumblr
  • Instapaper
  • Delicious