본문 바로가기
728x90
반응형

메시징플랫폼6

[Kafka] 카프카 시작 시 주키퍼 id 충돌 이슈 상황 전사 전기 장비 관련하여 점검이 있어 모든 테스트 PC가 재부팅됨. 주키퍼와 브로커는 자동 재시작처리하지 않아 수동으로 시작하려고 했더니 에러 발생 에러 내용 [2024-02-13 14:34:40,718] ERROR Error while creating ephemeral at /brokers/ids/3, node already exists and owner '144143570463227906' does not match current session '216389134594146305' (kafka.zk.KafkaZkClient$CheckedEphemeral) [2024-02-13 14:34:40,723] ERROR [KafkaServer id=3] Fatal error during KafkaServ.. 2024. 2. 28.
[Confluent Jdbc Sink] 10.6.x Release note 주요 내용 정리 목적 주요 변경점 파악하여 인프라 확장 설계시 참고하기 위함 버전별 Release note 요약 Version 10.6.5 커넥터의 로깅을 개선함 Version 10.6.4 JDBC 소스 커넥터가 Sybase jConnect JDBC 4 드라이버를 지원하도록 수정함 SQL문을 조건적으로 마스킹하는 설정이 추가됨 Version 10.6.3 - Version 10.6.2 오라클 DB의 CLOB 컬럼에 대해 setChracterStream에 길이 파라미터를 추가하여 성능을 개선함 Version 10.6.1 Sysbase DB에 JDBC 싱크 커넥터가 널 값을 포함한 레코드를 전송하는 것을 실패하는 버그가 수정됨 BatchUpdateException으로부터 민감성 데이터를 제거함 Version 10.6.0 in.. 2024. 2. 20.
[Kafka] 3.5.x Release note 주요 내용 정리 목적 카프카 브로커의 버전 업그레이드 시 발생할 수 있는 사이드 이펙트를 사전파악 및 대응, 신기술에 대한 도입 검토하기 위함 Release note Clause 3.5.0 Notable Changes 키당 여러 레코드 버전을 저장할 수 있는 새로운 상태 저장소 유형인 "버전별 키-값 저장소"가 도입되어, 타임스탬프가 지정된 타임스탬프 기준의 최신 레코드(키당)를 반환하는 타임스탬프 검색 작업이 가능해짐 Table 집계 시맨틱이 더욱 개선되어 이제 가짜 중간 결과를 방지함 카프카 스트림즈의 ProductionExceptionHandler가 개선되어 이제 직렬화 에러를 커버함 만료된 alterConfigs API 대신 미러메이커는 이제 토픽 설정을 동기화하기 위해 incrementalAlterConfigs.. 2024. 2. 18.
[Kafka] 3.2.x Release note 주요 내용 정리 목적 카프카 브로커의 버전 업그레이드 시 발생할 수 있는 사이드 이펙트를 사전파악 및 대응, 신기술에 대한 도입 검토하기 위함 Release note Clause 3.2.0 Notable Changes 프로듀서에 대한 Idempotence 설정이 다른 설정과 충돌하지 않으면 기본적으로 활성화됨. 3.0.0과 3.1.0에서는 버그가 있어 이 기능을 막았고 명시적으로 enable.idempotence를 true로 설정했어야 적용되었음. 3.0.1과 3.1.1, 3.2.0에서는 기본적으로 동작을 함 카프카가 보안 이슈로 log4j와 slf4j-log4j12를 reload4j와 slf4j-reload4j로 교체함 기본 classpath에서 예시 커넥터로 FileStreamSourceConnector와 FileS.. 2024. 2. 14.
728x90
반응형