golang 구동 kafka

kafka 안내
kafka 는 높 은 스루풋 의 분포 식 게시 구독 메시지 시스템 입 니 다.
특징.

O (1) 의 디스크 데이터 구 조 를 통 해 정 보 를 지속 적 으로 제공 합 니 다. 이러한 구 조 는 TB 의 메시지 로 저장 되 더 라 도 장시간 안정 적 인 성능 을 유지 할 수 있 습 니 다.

높 은 스루풋, 아주 일반적인 하드웨어 라 도 kafka 는 초당 수백 만 의 소식 을 지원 할 수 있 습 니 다.

kafka 서버 와 소비 기 클 러 스 터 를 통 해 파 티 션 메 시 지 를 지원 합 니 다

hadop 병렬 데이터 로드 를 지원 합 니 다.

kafka 구성 부분

Broker

kafka 클 러 스 터 는 하나 이상 의 서버 를 포함 하고 있 습 니 다. 이 서버 는 broker 라 고 합 니 다.

Topic

kafka 클 러 스 터 에 발 표 된 모든 메 시 지 는 하나의 유형 이 있 습 니 다. 이 유형 은 Topic 이 라 고 합 니 다. (물리 적 으로 서로 다른 Topic 메 시 지 를 따로 저장 합 니 다. 논리 적 으로 Topic 메 시 지 는 하나 이상 의 broker 에 저장 되 지만 사용 자 는 정 보 를 지정 한 Topic 만 있 으 면 데 이 터 를 생산 하거나 소비 할 수 있 습 니 다. 데이터 가 어디 에 저장 되 는 지 에 관심 이 있 습 니까?)

Partition

Partition 은 물리 적 인 개념 으로 모든 Topic 에는 하나 이상 의 Partition 이 포함 되 어 있 습 니 다.

Producer

Kafka broker 에 발표 하 는 일 을 맡 았 습 니 다.

Consumer

메시지 소비자, kafka broker 에 게 메 시 지 를 읽 는 클 라 이언 트

Consumer Group

모든 Consumer 는 특정한 Consumer Group 에 속 합 니 다. (consumer 마다 group name 을 지정 할 수 있 습 니 다. group name 을 지정 하지 않 으 면 기본 group 에 속 합 니 다)
golang 구동 kafka

go get github