CWN(CHANGE WITH NEWS) - 오픈소스 분산데이터 스트리밍 소프트웨어 Apache Kafka 2.3 버전 출시

  • 맑음임실4.6℃
  • 맑음천안4.3℃
  • 맑음강릉11.5℃
  • 맑음울진8.4℃
  • 맑음구미4.7℃
  • 맑음고창군7.0℃
  • 안개홍성7.7℃
  • 맑음홍천3.2℃
  • 맑음남원6.0℃
  • 맑음고산14.7℃
  • 맑음동두천5.5℃
  • 맑음고흥7.6℃
  • 맑음진주4.3℃
  • 맑음합천5.3℃
  • 맑음영광군6.0℃
  • 맑음정선군5.6℃
  • 맑음울릉도13.5℃
  • 맑음서청주8.6℃
  • 맑음완도12.4℃
  • 맑음여수11.4℃
  • 맑음서산4.8℃
  • 맑음청송군0.9℃
  • 맑음고창4.7℃
  • 구름조금속초12.1℃
  • 안개수원6.2℃
  • 맑음산청4.8℃
  • 구름조금인천9.5℃
  • 맑음순창군4.9℃
  • 맑음태백5.6℃
  • 구름많음파주5.4℃
  • 맑음영월3.5℃
  • 맑음보성군8.2℃
  • 맑음상주9.3℃
  • 맑음대관령4.1℃
  • 맑음목포11.9℃
  • 맑음제주14.7℃
  • 맑음대구6.0℃
  • 맑음제천2.6℃
  • 맑음함양군3.3℃
  • 맑음밀양4.7℃
  • 맑음양평4.7℃
  • 맑음부안8.9℃
  • 맑음철원6.8℃
  • 맑음대전9.2℃
  • 맑음북춘천1.1℃
  • 맑음성산12.1℃
  • 맑음영덕9.5℃
  • 맑음장흥5.0℃
  • 맑음동해8.9℃
  • 맑음부여8.6℃
  • 맑음서귀포14.1℃
  • 맑음경주시4.4℃
  • 맑음양산시7.6℃
  • 맑음북창원9.8℃
  • 맑음장수3.1℃
  • 맑음의성1.5℃
  • 안개청주8.8℃
  • 구름많음서울8.9℃
  • 맑음이천4.8℃
  • 맑음부산12.6℃
  • 구름많음강화5.6℃
  • 맑음금산5.0℃
  • 맑음거제10.7℃
  • 맑음통영12.2℃
  • 흐림군산8.9℃
  • 맑음전주8.6℃
  • 맑음북부산6.3℃
  • 맑음거창2.8℃
  • 맑음순천3.7℃
  • 맑음포항11.6℃
  • 맑음강진군7.1℃
  • 맑음광주10.6℃
  • 맑음문경6.3℃
  • 맑음창원9.7℃
  • 맑음원주6.4℃
  • 맑음광양시9.1℃
  • 맑음영주1.3℃
  • 맑음흑산도12.6℃
  • 맑음울산9.3℃
  • 맑음안동4.3℃
  • 구름조금보령6.4℃
  • 맑음춘천2.5℃
  • 맑음정읍8.1℃
  • 맑음진도군6.9℃
  • 맑음보은3.3℃
  • 맑음봉화-0.7℃
  • 맑음남해9.6℃
  • 구름조금인제2.2℃
  • 맑음북강릉10.2℃
  • 맑음세종7.6℃
  • 맑음추풍령4.0℃
  • 맑음김해시8.9℃
  • 맑음해남6.0℃
  • 맑음충주4.6℃
  • 안개백령도10.2℃
  • 맑음의령군3.4℃
  • 맑음영천3.4℃
  • 2025.11.25 (화)

오픈소스 분산데이터 스트리밍 소프트웨어 Apache Kafka 2.3 버전 출시

김진범 / 기사승인 : 2019-07-11 16:19:07
  • -
  • +
  • 인쇄

kafka.apache.org

Apache Kafka 팀은 오픈 소스 분산 데이터 스트리밍 소프트웨어인 Apache Kafka 2.3의 최신 버전을 출시했다.
최신 버전에는 Kafka Core, Connect 및 Streams REST API에 대한 몇가지 개선 사항이 포함되어있다. 또한 새로운 최대 로그 압축 지연이 추가되었으며 SocketServer 프로세서의 파티션 모니터링 및 공정성 개선 등을 개선했다.


IRA는 Kafka가 로그 세그먼트 만 확인해야하는 프로세스를 최적화한다. 이전 버전에서는 로그 복구에 필요한 시간이 로그 수에 비례하지 않았다. Kafka 2.3에서는 플러시되지 않은 로그 세그먼트 수에 비례하여 브로커 시작 시간이 50% 단축 되었다.


Kafka Core는 최소 수의 동기화 복제본을 가진 파티션을 보여주는 메트릭을 추가했다. 이러한 메트릭을 모니터링함으로써 사용자는 복제 부족 상태가 될 것으로 예상되는 파티션을 볼 수 있다. 또한, -under-min-isr 명령 행 플래그가 kafka-topics 명령에 추가되었다. 이를 통해 사용자는 최소의 동기화 복제본 수보다 적은 항목을 쉽게 볼 수 있게 되었다.

이전 버전에서는 최신 키가 작성된 후 1차 근사치의 이전 키 값이 잠시 후에 압축되다. 이번 배포에서는 이전 값을 고수 할 최대 시간을 설정할 수 있다. 새로운 매개 변수 max.log.compation.time.ms는 압축된 주제에서 오래된 값이 지속될 수 있는 기간을 지정한다. 이를 통해 Apache Kafka는 GDPR과 같은 데이터 보존 규정을 준수 할 수 있다.

Apache Kafka 2.3은 새로운 연결에 우선하여 기존 연결을 우선 순위에두고 연결 폭풍에 대한 브로커의 복원력을 향상시킨다. 또한 브로커 설정 당 최대 연결 수를 추가한다.Core Kafka는 Replica Fetcher에서 오류 처리 기능을 개선했다.

Kafka Connect에서는 작업자 작업이 사용 가능한 작업자 노드로 분산된다. 커넥터를 다시 구성하거나 새 커넥터를 배포 할 때 뿐만 아니라 작업자를 추가하거나 제거 할 때 작업을 Connect 클러스터에서 다시 균형을 조정해야한다. 이렇게하면 모든 작업자 노드가 Connect 작업을 공정하게 공유 할 수 있다. Kafka 2.3을 사용하면 구성을 쉽게 변경할 수 있다. 또한 Kafka Connect는 Connect 작업자 로그에 커넥터 컨텍스트를 추가했다.

Kafka Streams에는 주 저장소에 타임 스탬프가 포함된다. 이를 통해 KTables의 순서가 잘못된 메시지를 처리하고 KTables 용 TTL을 구현하는 것과 같은 미래의 기능을 보장 할 수있는 토대가 마련된다.

[저작권자ⓒ CWN(CHANGE WITH NEWS). 무단전재-재배포 금지]

최신기사

뉴스댓글 >

- 띄어 쓰기를 포함하여 250자 이내로 써주세요.
- 건전한 토론문화를 위해, 타인에게 불쾌감을 주는 욕설/비방/허위/명예훼손/도배 등의 댓글은 표시가 제한됩니다.

댓글 0

Today

Hot Issue