기능 분석

[jinhwan2]

개요

스펙은 kafka-admin-client의 스펙에 종속된다.

논의 필요 내용

어디까지 구현해볼까?

kafka-admin-client 인터페이스

3.3.1 기준

cluster #13

describeCluster

• [x] clusterId
• [x] Nodes
• [x] Controller
• [x] AclOperation

topic #6

• [x] createTopics // 토픽 생성
• [x] deleteTopics // 토픽 삭제
• [x] listTopics // 토픽 목록조회
• [x] describeTopics // 토픽 상세조회

config #10

• [x] describeConfigs
• ~alterConfigs~ // deprecated ( use incrementalAlterConfigs )
• [x] incrementalAlterConfigs

consumer #12

• [ ] describeConsumerGroups
• [ ] listConsumerGroups
• [ ] deleteConsumerGroups
• [ ] removeMembersFromConsumerGroup
• [ ] listConsumerGroupOffsets
• [ ] deleteConsumerGroupOffsets
• [ ] alterConsumerGroupOffsets

acl

describeAcls createAcls deleteAcls

file alterReplicaLogDirs describeLogDirs describeReplicaLogDirs

token createDelegationToken renewDelegationToken expireDelegationToken describeDelegationToken

etc.. createPartitions deleteRecords electLeaders alterPartitionReassignments listPartitionReassignments listOffsets describeClientQuotas alterClientQuotas describeUserScramCredentials alterUserScramCredentials describeFeatures updateFeatures describeMetadataQuorum unregisterBroker describeProducers describeTransactions abortTransaction

fenceProducers listTransactions

monitoring

metrics

[lsh110600]

TopicController 코드 중, PUT request 보내는 부분 변경이 필요합니다.

1. method 이름 변경
2. 두 번째 인자에 @RequestBody 어노테이션 추가

[As-is] @PutMapping("/topics/{topicName}")

boolean updateBrokerConfig(@PathVariable String topicName, ConfigModifyRequest configModifyRequest) throws ExecutionException, InterruptedException {
    return this.topicService.updateConfig(topicName, configModifyRequest);
}

---

[To-be] @PutMapping("/topics/{topicName}")

boolean updateTopicConfig(@PathVariable String topicName, @RequestBody ConfigModifyRequest configModifyRequest) throws ExecutionException, InterruptedException {
    return this.topicService.updateConfig(topicName, configModifyRequest);
}

[jinhwan2]

TopicController 코드 중, PUT request 보내는 부분 변경이 필요합니다.

1. method 이름 변경
2. 두 번째 인자에 @requestbody 어노테이션 추가

[As-is] @PutMapping("/topics/{topicName}")

boolean updateBrokerConfig(@PathVariable String topicName, ConfigModifyRequest configModifyRequest) throws ExecutionException, InterruptedException {
    return this.topicService.updateConfig(topicName, configModifyRequest);
}

[To-be] @PutMapping("/topics/{topicName}")

boolean updateTopicConfig(@PathVariable String topicName, @RequestBody ConfigModifyRequest configModifyRequest) throws ExecutionException, InterruptedException {
    return this.topicService.updateConfig(topicName, configModifyRequest);
}

에고 제가 실수를 했네요 ㅎㅎ 버그제보는 댓글보다 이슈하나따서 버그로 리포팅 해주셔도 돼요

이건 집가서 수정할게요~ 감사합니다 💯