Kafka를 이용하다보면 Broker 버전이 서로 다른 cluster를 사용할때가 있다. 아무래도 먼저 클러스터를 구성한 브로커인경우 업그레이드 하기가 어렵기 때문에 여러개의 버전을 사용할수 있다. 이와 관련해서 자료를 찾아보니 0.10.0 버전을 제외하고는 모든 java client 버전은 broker에 호환이 된다. 물론 각각의 버전에 따른 기능은 지원이 되지 않는 것이 있을수가 있다.
- 아래는 Client 라이브러리 관련 호한성을 나타낸것이다.
Reference
- https://cwiki.apache.org/confluence/display/KAFKA/Compatibility+Matrix
Broker 0.10.0
- Basic client compatibility:
- Java: clients <= 0.10.0 or >= 0.10.2
- KIP-35 enabled clients: any version
- Kafka Streams: version 0.10.0
- Versions >= 0.10.2 not supported because they require CreateTopics support introduced in 0.10.1
- Kafka Connect: versions <= 0.10.0 or >= 0.10.2
- Features that newer clients might notice missing:
- AdminClient requests
Broker 0.10.1
- Basic client compatibility:
- Java: any version
- KIP-35 enabled clients: any version
- Kafka Streams: any version
- Kafka Connect: versions <= 0.10.1
- Features that newer clients might notice missing:
- AdminClient
Broker 0.10.2
- Basic client compatibility:
- Java: any version
- KIP-35 enabled clients: any version
- Kafka Streams: any version
- Kafka Connect: any version
- Features that newer clients might notice missing:
- AdminClient
Broker 0.11.0
- Basic client compatibility:
- Java: any version
- KIP-35 enabled clients: any version
- Kafka Streams: any version
- Kafka Connect: any version
- Features that newer clients might notice missing:
Broker 1.0.0
- Basic client compatibility:
- Java: any version
- KIP-35 enabled clients: any version
- Kafka Streams: any version
- Kafka Connect: any version
- Features that newer clients might notice missing:
'실시간 데이터 처리 > Kafka' 카테고리의 다른 글
Kafka Producer Partition Leader / Ack, Timeout (0) | 2018.07.31 |
---|---|
Kafka Offset Monitor (0) | 2018.06.29 |
Kafka Partition과 Offset (0) | 2018.06.11 |
Kafka Topic / Message Consumer and Producer 명령어 (0) | 2018.05.20 |
Zero Copy (0) | 2017.07.04 |