AdminClient 개요

최종적 일관성

AdminClient API가 리턴하는 Future 객체의 완료 여부는 컨트롤러의 상태가 완전히 업데이트된 상태를 기준

• 여러 컨트롤러 중 리더 컨트롤러 1개만 인지하면 Future 객체의 결과를 알 수 있음
• 전파가 일어나는 동안 토픽 리스트를 확인하는 listTopics 요청을 보내면 다른 컨트롤러들은 정보를 모를 수 있음
• 정확한 타이밍은 알 수 없음

옵션

AdminClient의 각 메서드가 특정한 Option 객체를 인자로 받음

• listTopics 메서드는 ListTopicsOptions 객체를 인자로 받음

수평 구조

모든 어드민 기능이 KafkaAdminClient에 구현되어 있음

• 하나의 인터페이스에만 의존하면 되므로 IDE 자동완성 등 편의성이 있음

AdminClient 사용법

import org.apache.kafka.clients.admin.AdminClient;
import org.apache.kafka.clients.admin.AdminClientConfig;
import java.time.Duration;
import java.util.Properties;

public class KafkaAdminClient {
    public static void main(String[] args) {
        Properties props = new Properties();
        props.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");
        AdminClient admin = AdminClient.create(props);

        admin.close(Duration.ofSeconds(30));
    }
}

리스너 관련 프로토콜

• PLAINTEXT: 보안적인 요구가 없는 텍스트기반의 통신
• SSL: 클라이언트와 브로커간 암호화 보안 설정
• SASL_SSL: SASL을 통해 SSL을 적용한 리스너
  • 인증 및 권한 부여할때 사용

request.timeout.ms

AdminClient의 응답을 기다릴 수 있는 시간의 최대값을 정의