프로그램 내에서 코드로 카프카 관리하기

• 카프카 관리에 사용하는 여러 CLI, GUI 툴이 있다
• 때로는 클라이언트 애플리케이션에서 직접 관리 명령을 내려야 할 때도 있다
• 사용자 입장에 기반해서 새 토픽을 생성하는 경우는 흔하다
• 과거에 AdminClient가 없던 시절에는 producer.send()에서 토픽이 존재하지 않더라도 할 수 있는 게 별로 없었다
  • 사용자한테 알려주거나
  • 자동 토픽 생성 기능이 켜져있기를 기대하거나

Admin Client 개요

비동기적이고 최종적 일관성을 지니는 API

• AdminClient는 비동기적으로 작동한다
• 각 메서드는 클러스터로 요청을 보낸 뒤 Future 객체를 반환
• AdminClient는 Future 객체를 Result 객체 안에 감싸는데, 이는 작업이 끝날 때까지 대기하거나 작업 결과에 대해 일반적으로 뒤이어 쓰인 작업을 수행하는 헬퍼 메서드를 가지고 있다
• 카프카 컨트롤러로부터 브로커로의 메타데이터 전파가 비동기적으로 이루어지므로, Future 객체들은 컨트롤러의 상태가 완전히 업데이트된 시점에 완료된 것으로 간주한다
• 즉, 이때 다른 브로커는 업데이트되지 않았을 수도 있다

• 최종적 일관성(eventual consistency)

옵션

• 각 메서드별로 특정한 Option 받는다
• 모든 메서드는 timeoutMs 매개변수를 지니고 있다.
  • 클라이언트가 TimeoutException을 발생시키기 전, 클러스터로부터 응답을 기다리는 시간을 조정

수평 구조

• 모든 어드민 작업은 KafkaAdminClient에 구현되어 있는 아파치 카프카 프로토콜을 사용해서 이루어진다
• 여기엔 객체 의존 관계나 네임스페이스가 없다
• 인터페이스가 다소 커서 논라란이 있지만, 덕분에 어드민 작업을 수행할 때 필요한 메서드 하나만 찾아서 쓰면 된다