kafka admin api - Githubissues

yeomko22 / TIL

Today I learned

1 stars 0 forks source link

kafka admin api #109

Open yeomko22 opened 2 years ago

yeomko22 commented 2 years ago

admin API

kafka 내부 옵션 확인하는 확실한 방법: 브로커에 접속, 카프카 브로커 옵션 확인, 그러나 귀찮다!
내부 옵션 설정 및 조회를 위해 AdminClient 클래스를 제공한다.

AdminClient 활용 예시

구독하는 토픽의 파티션 개수만큼 스레드를 새엇ㅇ하고 싶을 때, 스레드 생성 전에 해당 토픽의 파티션 개수를 admin API를 통해 가져옴
웹 대쉬보드를 통해 ACL이 적용된 클러스터의 리소스 권한 규칙 추가 가능
특정 토픽의 데이터 양이 늘어남을 감지하고 AdminClient 클래스로 해당 토픽의 파티션 늘려주기

adminClient가 제공하는 주요 메서드

describeCluster(DescribeClusterOptions options)
listTopics(ListTopicsOptions options)
listConsumerGroups(ListConsumerGroupsOptions options)
createTopics(Collection<NewTopic> newTopics, CreateTopicsOptions options)
createPartitions(Map<String, NewPartitions> newPartitions, CreatePartitionsOptions options)
createAcls(Collection<AclBinding> acls, CreateAclsOptions options)