mindol1004/spring-cloud-gateway
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Kafka Producer & Consumer 문서 추가

Browse Source
This commit is contained in:
roy-zz
2022-04-26 22:32:16 +09:00
parent bbf933904f
commit f1fb001b6b
14 changed files with 1542 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

86
document/kafka/pub_sub.md Normal file
View File

@@ -0,0 +1,86 @@
[이전 장(링크)](https://imprint.tistory.com/231) 에서는 `Kafka`를 소개하고 설치해보는 시간을 가졌다.
이번 장에서는 `Kafka`의 Producer와 Consumer를 사용하여 통신하는 방법에 대해서 알아본다.
모든 소스 코드는 [깃 허브 (링크)](https://github.com/roy-zz/spring-cloud) 에 올려두었다.
---
### Producer & Consumer
1. Zoopeeker 실행
Kafka를 설치하기 위해 다운받은 압축파일의 압축이 풀린 경로로 이동하여 아래의 커맨드를 입력한다.
```bash
$ ./bin/zookeeper-server-start.sh ./config/zookeeper.properties
```
아래의 이미지와 같이 출력된다면 정상적으로 `Zookeeper`가 실행된 것이다.
![](pub_sub_image/start-zookeeper.png)
2. Kafka 실행
Zookeeper를 실행시킨 경로에서 아래의 커맨드를 입력한다.
```bash
./bin/kafka-server-start.sh ./config/server.properties
```
아래의 이미지와 같이 출력된다면 정상적으로 `Kafka`가 실행된 것이다.
![](pub_sub_image/start-kafka.png)
3. Topic 생성
아래의 커맨드와 같이 원하는 토픽 이름으로 토픽을 생성한다.
필자의 경우 roy-topic이라는 이름을 사용하였다.
```bash
$ ./bin/kafka-topics.sh --bootstrap-server localhost:9092 --create --topic roy-topic --partitions 1
```
아래의 이미지와 같이 출력된다면 정상적으로 토픽이 생성된 것이다.
![](pub_sub_image/create-topic.png)
4. Producer 생성
Topic을 생성한 경로와 동일한 경로에서 아래의 커맨드를 입력하여 `Producer`를 생성한다.
주의할 점은 3단계에서 생성한 토픽을 지정해야한다.
```bash
$ ./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic roy-topic
```
5. Consumer 생성
Producer와 동일하게 아래의 커맨드를 사용하여 `Consumer`를 생성한다.
여기서 옵션으로 사용된 `--from-beginning`는 데이터의 처음부터 읽어 오겠다는 의미다.
```bash
$ ./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic roy-topic --from-beginning
```
6. 데이터 전달
Producer에서 원하는 데이터를 전달해본다.
![](pub_sub_image/transfer-data.png)
정상적으로 데이터가 전달되는 것을 확인할 수 있다.
7. 복수 Consumers 테스트
우리는 `Kafka`를 소개할 때 `Consumer`가 여러개 있더라도 모두 같은 데이터를 받을 수 있다고 학습하였다.
직접 여러개의 Conusmer를 생성하여 동일한 데이터를 받을 수 있는지 확인해본다.
![](pub_sub_image/multiple-consumers.png)
이미지에서 가장 좌측은 `Producer`이며 우측의 세 개의 창은 모두 다른 `Consumer`다.
여러개의 `Consumer`가 존재하더라도 동일한 데이터를 받아오는 것을 확인할 수 있다.
---
**참고한 강의:**
- https://www.inflearn.com/course/%EC%8A%A4%ED%94%84%EB%A7%81-%ED%81%B4%EB%9D%BC%EC%9A%B0%EB%93%9C-%EB%A7%88%EC%9D%B4%ED%81%AC%EB%A1%9C%EC%84%9C%EB%B9%84%EC%8A%A4

BIN
document/kafka/pub_sub_image/create-topic.png Normal file
View File

Binary file not shown.
Side by Side

After

Width:  |  Height:  |  Size: 12 KiB

BIN
document/kafka/pub_sub_image/multiple-consumers.png Normal file
View File

Binary file not shown.
Side by Side

After

Width:  |  Height:  |  Size: 68 KiB

BIN
document/kafka/pub_sub_image/start-kafka.png Normal file
View File

Binary file not shown.
Side by Side

After

Width:  |  Height:  |  Size: 135 KiB

BIN
document/kafka/pub_sub_image/start-zookeeper.png Normal file
View File

Binary file not shown.
Side by Side

After

Width:  |  Height:  |  Size: 120 KiB

BIN
document/kafka/pub_sub_image/transfer-data.png Normal file
View File

Binary file not shown.
Side by Side

After

Width:  |  Height:  |  Size: 43 KiB

54
thirdparty/kafka_2.13-3.1.0/logs/controller.log vendored Normal file
View File

@@ -0,0 +1,54 @@
[2022-04-26 22:11:29,320] DEBUG preRegister called. Server=com.sun.jmx.mbeanserver.JmxMBeanServer@5bcea91b, name=log4j:logger=kafka.controller (kafka.controller)
[2022-04-26 22:13:46,618] INFO [ControllerEventThread controllerId=0] Starting (kafka.controller.ControllerEventManager$ControllerEventThread)
[2022-04-26 22:13:46,664] INFO [Controller id=0] 0 successfully elected as the controller. Epoch incremented to 1 and epoch zk version is now 1 (kafka.controller.KafkaController)
[2022-04-26 22:13:46,668] INFO [Controller id=0] Creating FeatureZNode at path: /feature with contents: FeatureZNode(Enabled,Features{}) (kafka.controller.KafkaController)
[2022-04-26 22:13:46,713] INFO [Controller id=0] Registering handlers (kafka.controller.KafkaController)
[2022-04-26 22:13:46,717] INFO [Controller id=0] Deleting log dir event notifications (kafka.controller.KafkaController)
[2022-04-26 22:13:46,720] INFO [Controller id=0] Deleting isr change notifications (kafka.controller.KafkaController)
[2022-04-26 22:13:46,723] INFO [Controller id=0] Initializing controller context (kafka.controller.KafkaController)
[2022-04-26 22:13:46,737] INFO [Controller id=0] Initialized broker epochs cache: HashMap(0 -> 25) (kafka.controller.KafkaController)
[2022-04-26 22:13:46,743] DEBUG [Controller id=0] Register BrokerModifications handler for Set(0) (kafka.controller.KafkaController)
[2022-04-26 22:13:46,748] DEBUG [Channel manager on controller 0]: Controller 0 trying to connect to broker 0 (kafka.controller.ControllerChannelManager)
[2022-04-26 22:13:46,757] INFO [RequestSendThread controllerId=0] Starting (kafka.controller.RequestSendThread)
[2022-04-26 22:13:46,760] INFO [Controller id=0] Currently active brokers in the cluster: Set(0) (kafka.controller.KafkaController)
[2022-04-26 22:13:46,760] INFO [Controller id=0] Currently shutting brokers in the cluster: HashSet() (kafka.controller.KafkaController)
[2022-04-26 22:13:46,760] INFO [Controller id=0] Current list of topics in the cluster: HashSet() (kafka.controller.KafkaController)
[2022-04-26 22:13:46,761] INFO [Controller id=0] Fetching topic deletions in progress (kafka.controller.KafkaController)
[2022-04-26 22:13:46,764] INFO [Controller id=0] List of topics to be deleted: (kafka.controller.KafkaController)
[2022-04-26 22:13:46,764] INFO [Controller id=0] List of topics ineligible for deletion: (kafka.controller.KafkaController)
[2022-04-26 22:13:46,765] INFO [Controller id=0] Initializing topic deletion manager (kafka.controller.KafkaController)
[2022-04-26 22:13:46,765] INFO [Topic Deletion Manager 0] Initializing manager with initial deletions: Set(), initial ineligible deletions: HashSet() (kafka.controller.TopicDeletionManager)
[2022-04-26 22:13:46,766] INFO [Controller id=0] Sending update metadata request (kafka.controller.KafkaController)
[2022-04-26 22:13:46,778] INFO [ReplicaStateMachine controllerId=0] Initializing replica state (kafka.controller.ZkReplicaStateMachine)
[2022-04-26 22:13:46,779] INFO [ReplicaStateMachine controllerId=0] Triggering online replica state changes (kafka.controller.ZkReplicaStateMachine)
[2022-04-26 22:13:46,784] INFO [ReplicaStateMachine controllerId=0] Triggering offline replica state changes (kafka.controller.ZkReplicaStateMachine)
[2022-04-26 22:13:46,784] DEBUG [ReplicaStateMachine controllerId=0] Started replica state machine with initial state -> HashMap() (kafka.controller.ZkReplicaStateMachine)
[2022-04-26 22:13:46,785] INFO [PartitionStateMachine controllerId=0] Initializing partition state (kafka.controller.ZkPartitionStateMachine)
[2022-04-26 22:13:46,786] INFO [PartitionStateMachine controllerId=0] Triggering online partition state changes (kafka.controller.ZkPartitionStateMachine)
[2022-04-26 22:13:46,787] INFO [RequestSendThread controllerId=0] Controller 0 connected to localhost:9092 (id: 0 rack: null) for sending state change requests (kafka.controller.RequestSendThread)
[2022-04-26 22:13:46,789] DEBUG [PartitionStateMachine controllerId=0] Started partition state machine with initial state -> HashMap() (kafka.controller.ZkPartitionStateMachine)
[2022-04-26 22:13:46,789] INFO [Controller id=0] Ready to serve as the new controller with epoch 1 (kafka.controller.KafkaController)
[2022-04-26 22:13:46,801] INFO [Controller id=0] Partitions undergoing preferred replica election: (kafka.controller.KafkaController)
[2022-04-26 22:13:46,801] INFO [Controller id=0] Partitions that completed preferred replica election: (kafka.controller.KafkaController)
[2022-04-26 22:13:46,802] INFO [Controller id=0] Skipping preferred replica election for partitions due to topic deletion: (kafka.controller.KafkaController)
[2022-04-26 22:13:46,802] INFO [Controller id=0] Resuming preferred replica election for partitions: (kafka.controller.KafkaController)
[2022-04-26 22:13:46,804] INFO [Controller id=0] Starting replica leader election (PREFERRED) for partitions triggered by ZkTriggered (kafka.controller.KafkaController)
[2022-04-26 22:13:46,826] INFO [Controller id=0] Starting the controller scheduler (kafka.controller.KafkaController)
[2022-04-26 22:13:51,829] INFO [Controller id=0] Processing automatic preferred replica leader election (kafka.controller.KafkaController)
[2022-04-26 22:13:51,830] TRACE [Controller id=0] Checking need to trigger auto leader balancing (kafka.controller.KafkaController)
[2022-04-26 22:17:10,876] INFO [Controller id=0] New topics: [Set(roy-topic)], deleted topics: [HashSet()], new partition replica assignment [Set(TopicIdReplicaAssignment(roy-topic,Some(S_-AeMmpTxKKSVvRifuAWA),Map(roy-topic-0 -> ReplicaAssignment(replicas=0, addingReplicas=, removingReplicas=))))] (kafka.controller.KafkaController)
[2022-04-26 22:17:10,877] INFO [Controller id=0] New partition creation callback for roy-topic-0 (kafka.controller.KafkaController)
[2022-04-26 22:18:51,841] INFO [Controller id=0] Processing automatic preferred replica leader election (kafka.controller.KafkaController)
[2022-04-26 22:18:51,841] TRACE [Controller id=0] Checking need to trigger auto leader balancing (kafka.controller.KafkaController)
[2022-04-26 22:18:51,843] DEBUG [Controller id=0] Topics not in preferred replica for broker 0 Map() (kafka.controller.KafkaController)
[2022-04-26 22:18:51,844] TRACE [Controller id=0] Leader imbalance ratio for broker 0 is 0.0 (kafka.controller.KafkaController)
[2022-04-26 22:23:26,454] INFO [Controller id=0] New topics: [Set(__consumer_offsets)], deleted topics: [HashSet()], new partition replica assignment [Set(TopicIdReplicaAssignment(__consumer_offsets,Some(oijCkFadRXmdKsrjPPD9Yg),HashMap(__consumer_offsets-22 -> ReplicaAssignment(replicas=0, addingReplicas=, removingReplicas=), __consumer_offsets-30 -> ReplicaAssignment(replicas=0, addingReplicas=, removingReplicas=), __consumer_offsets-25 -> ReplicaAssignment(replicas=0, addingReplicas=, removingReplicas=), __consumer_offsets-35 -> ReplicaAssignment(replicas=0, addingReplicas=, removingReplicas=), __consumer_offsets-37 -> ReplicaAssignment(replicas=0, addingReplicas=, removingReplicas=), __consumer_offsets-38 -> ReplicaAssignment(replicas=0, addingReplicas=, removingReplicas=), __consumer_offsets-13 -> ReplicaAssignment(replicas=0, addingReplicas=, removingReplicas=), __consumer_offsets-8 -> ReplicaAssignment(replicas=0, addingReplicas=, removingReplicas=), __consumer_offsets-21 -> ReplicaAssignment(replicas=0, addingReplicas=, removingReplicas=), __consumer_offsets-4 -> ReplicaAssignment(replicas=0, addingReplicas=, removingReplicas=), __consumer_offsets-27 -> ReplicaAssignment(replicas=0, addingReplicas=, removingReplicas=), __consumer_offsets-7 -> ReplicaAssignment(replicas=0, addingReplicas=, removingReplicas=), __consumer_offsets-9 -> ReplicaAssignment(replicas=0, addingReplicas=, removingReplicas=), __consumer_offsets-46 -> ReplicaAssignment(replicas=0, addingReplicas=, removingReplicas=), __consumer_offsets-41 -> ReplicaAssignment(replicas=0, addingReplicas=, removingReplicas=), __consumer_offsets-33 -> ReplicaAssignment(replicas=0, addingReplicas=, removingReplicas=), __consumer_offsets-23 -> ReplicaAssignment(replicas=0, addingReplicas=, removingReplicas=), __consumer_offsets-49 -> ReplicaAssignment(replicas=0, addingReplicas=, removingReplicas=), __consumer_offsets-47 -> ReplicaAssignment(replicas=0, addingReplicas=, removingReplicas=), __consumer_offsets-16 -> ReplicaAssignment(replicas=0, addingReplicas=, removingReplicas=), __consumer_offsets-28 -> ReplicaAssignment(replicas=0, addingReplicas=, removingReplicas=), __consumer_offsets-31 -> ReplicaAssignment(replicas=0, addingReplicas=, removingReplicas=), __consumer_offsets-36 -> ReplicaAssignment(replicas=0, addingReplicas=, removingReplicas=), __consumer_offsets-42 -> ReplicaAssignment(replicas=0, addingReplicas=, removingReplicas=), __consumer_offsets-3 -> ReplicaAssignment(replicas=0, addingReplicas=, removingReplicas=), __consumer_offsets-18 -> ReplicaAssignment(replicas=0, addingReplicas=, removingReplicas=), __consumer_offsets-15 -> ReplicaAssignment(replicas=0, addingReplicas=, removingReplicas=), __consumer_offsets-24 -> ReplicaAssignment(replicas=0, addingReplicas=, removingReplicas=), __consumer_offsets-17 -> ReplicaAssignment(replicas=0, addingReplicas=, removingReplicas=), __consumer_offsets-48 -> ReplicaAssignment(replicas=0, addingReplicas=, removingReplicas=), __consumer_offsets-19 -> ReplicaAssignment(replicas=0, addingReplicas=, removingReplicas=), __consumer_offsets-11 -> ReplicaAssignment(replicas=0, addingReplicas=, removingReplicas=), __consumer_offsets-2 -> ReplicaAssignment(replicas=0, addingReplicas=, removingReplicas=), __consumer_offsets-43 -> ReplicaAssignment(replicas=0, addingReplicas=, removingReplicas=), __consumer_offsets-6 -> ReplicaAssignment(replicas=0, addingReplicas=, removingReplicas=), __consumer_offsets-14 -> ReplicaAssignment(replicas=0, addingReplicas=, removingReplicas=), __consumer_offsets-20 -> ReplicaAssignment(replicas=0, addingReplicas=, removingReplicas=), __consumer_offsets-0 -> ReplicaAssignment(replicas=0, addingReplicas=, removingReplicas=), __consumer_offsets-44 -> ReplicaAssignment(replicas=0, addingReplicas=, removingReplicas=), __consumer_offsets-39 -> ReplicaAssignment(replicas=0, addingReplicas=, removingReplicas=), __consumer_offsets-12 -> ReplicaAssignment(replicas=0, addingReplicas=, removingReplicas=), __consumer_offsets-45 -> ReplicaAssignment(replicas=0, addingReplicas=, removingReplicas=), __consumer_offsets-1 -> ReplicaAssignment(replicas=0, addingReplicas=, removingReplicas=), __consumer_offsets-5 -> ReplicaAssignment(replicas=0, addingReplicas=, removingReplicas=), __consumer_offsets-26 -> ReplicaAssignment(replicas=0, addingReplicas=, removingReplicas=), __consumer_offsets-29 -> ReplicaAssignment(replicas=0, addingReplicas=, removingReplicas=), __consumer_offsets-34 -> ReplicaAssignment(replicas=0, addingReplicas=, removingReplicas=), __consumer_offsets-10 -> ReplicaAssignment(replicas=0, addingReplicas=, removingReplicas=), __consumer_offsets-32 -> ReplicaAssignment(replicas=0, addingReplicas=, removingReplicas=), __consumer_offsets-40 -> ReplicaAssignment(replicas=0, addingReplicas=, removingReplicas=))))] (kafka.controller.KafkaController)
[2022-04-26 22:23:26,454] INFO [Controller id=0] New partition creation callback for __consumer_offsets-22,__consumer_offsets-30,__consumer_offsets-25,__consumer_offsets-35,__consumer_offsets-37,__consumer_offsets-38,__consumer_offsets-13,__consumer_offsets-8,__consumer_offsets-21,__consumer_offsets-4,__consumer_offsets-27,__consumer_offsets-7,__consumer_offsets-9,__consumer_offsets-46,__consumer_offsets-41,__consumer_offsets-33,__consumer_offsets-23,__consumer_offsets-49,__consumer_offsets-47,__consumer_offsets-16,__consumer_offsets-28,__consumer_offsets-31,__consumer_offsets-36,__consumer_offsets-42,__consumer_offsets-3,__consumer_offsets-18,__consumer_offsets-15,__consumer_offsets-24,__consumer_offsets-17,__consumer_offsets-48,__consumer_offsets-19,__consumer_offsets-11,__consumer_offsets-2,__consumer_offsets-43,__consumer_offsets-6,__consumer_offsets-14,__consumer_offsets-20,__consumer_offsets-0,__consumer_offsets-44,__consumer_offsets-39,__consumer_offsets-12,__consumer_offsets-45,__consumer_offsets-1,__consumer_offsets-5,__consumer_offsets-26,__consumer_offsets-29,__consumer_offsets-34,__consumer_offsets-10,__consumer_offsets-32,__consumer_offsets-40 (kafka.controller.KafkaController)
[2022-04-26 22:23:51,791] INFO [Controller id=0] Processing automatic preferred replica leader election (kafka.controller.KafkaController)
[2022-04-26 22:23:51,797] TRACE [Controller id=0] Checking need to trigger auto leader balancing (kafka.controller.KafkaController)
[2022-04-26 22:23:51,800] DEBUG [Controller id=0] Topics not in preferred replica for broker 0 HashMap() (kafka.controller.KafkaController)
[2022-04-26 22:23:51,800] TRACE [Controller id=0] Leader imbalance ratio for broker 0 is 0.0 (kafka.controller.KafkaController)
[2022-04-26 22:28:51,803] INFO [Controller id=0] Processing automatic preferred replica leader election (kafka.controller.KafkaController)
[2022-04-26 22:28:51,804] TRACE [Controller id=0] Checking need to trigger auto leader balancing (kafka.controller.KafkaController)
[2022-04-26 22:28:51,805] DEBUG [Controller id=0] Topics not in preferred replica for broker 0 HashMap() (kafka.controller.KafkaController)
[2022-04-26 22:28:51,805] TRACE [Controller id=0] Leader imbalance ratio for broker 0 is 0.0 (kafka.controller.KafkaController)

0
thirdparty/kafka_2.13-3.1.0/logs/kafka-authorizer.log vendored Normal file
View File

0
thirdparty/kafka_2.13-3.1.0/logs/kafka-request.log vendored Normal file
View File

129
thirdparty/kafka_2.13-3.1.0/logs/kafkaServer-gc.log vendored Normal file
View File

@@ -0,0 +1,129 @@
[2022-04-26T22:13:43.363+0900][gc,heap] Heap region size: 1M
[2022-04-26T22:13:43.372+0900][gc ] Using G1
[2022-04-26T22:13:43.372+0900][gc,heap,coops] Heap address: 0x00000007c0000000, size: 1024 MB, Compressed Oops mode: Zero based, Oop shift amount: 3
[2022-04-26T22:13:44.593+0900][gc,start ] GC(0) Pause Young (Concurrent Start) (Metadata GC Threshold)
[2022-04-26T22:13:44.593+0900][gc,task ] GC(0) Using 8 workers of 8 for evacuation
[2022-04-26T22:13:44.601+0900][gc,phases ] GC(0) Pre Evacuate Collection Set: 0.0ms
[2022-04-26T22:13:44.601+0900][gc,phases ] GC(0) Evacuate Collection Set: 7.4ms
[2022-04-26T22:13:44.601+0900][gc,phases ] GC(0) Post Evacuate Collection Set: 0.4ms
[2022-04-26T22:13:44.601+0900][gc,phases ] GC(0) Other: 0.8ms
[2022-04-26T22:13:44.601+0900][gc,heap ] GC(0) Eden regions: 44->0(44)
[2022-04-26T22:13:44.601+0900][gc,heap ] GC(0) Survivor regions: 0->7(7)
[2022-04-26T22:13:44.601+0900][gc,heap ] GC(0) Old regions: 0->0
[2022-04-26T22:13:44.601+0900][gc,heap ] GC(0) Humongous regions: 0->0
[2022-04-26T22:13:44.601+0900][gc,metaspace ] GC(0) Metaspace: 20756K->20756K(1069056K)
[2022-04-26T22:13:44.601+0900][gc ] GC(0) Pause Young (Concurrent Start) (Metadata GC Threshold) 44M->6M(1024M) 8.677ms
[2022-04-26T22:13:44.601+0900][gc,cpu ] GC(0) User=0.02s Sys=0.00s Real=0.01s
[2022-04-26T22:13:44.602+0900][gc ] GC(1) Concurrent Cycle
[2022-04-26T22:13:44.602+0900][gc,marking ] GC(1) Concurrent Clear Claimed Marks
[2022-04-26T22:13:44.602+0900][gc,marking ] GC(1) Concurrent Clear Claimed Marks 0.021ms
[2022-04-26T22:13:44.602+0900][gc,marking ] GC(1) Concurrent Scan Root Regions
[2022-04-26T22:13:44.604+0900][gc,marking ] GC(1) Concurrent Scan Root Regions 2.077ms
[2022-04-26T22:13:44.604+0900][gc,marking ] GC(1) Concurrent Mark (1.250s)
[2022-04-26T22:13:44.604+0900][gc,marking ] GC(1) Concurrent Mark From Roots
[2022-04-26T22:13:44.604+0900][gc,task ] GC(1) Using 2 workers of 2 for marking
[2022-04-26T22:13:44.604+0900][gc,marking ] GC(1) Concurrent Mark From Roots 0.183ms
[2022-04-26T22:13:44.604+0900][gc,marking ] GC(1) Concurrent Preclean
[2022-04-26T22:13:44.604+0900][gc,marking ] GC(1) Concurrent Preclean 0.028ms
[2022-04-26T22:13:44.604+0900][gc,marking ] GC(1) Concurrent Mark (1.250s, 1.250s) 0.255ms
[2022-04-26T22:13:44.604+0900][gc,start ] GC(1) Pause Remark
[2022-04-26T22:13:44.606+0900][gc,stringtable] GC(1) Cleaned string and symbol table, strings: 7217 processed, 0 removed, symbols: 63664 processed, 32 removed
[2022-04-26T22:13:44.607+0900][gc ] GC(1) Pause Remark 7M->7M(1024M) 2.440ms
[2022-04-26T22:13:44.607+0900][gc,cpu ] GC(1) User=0.01s Sys=0.00s Real=0.00s
[2022-04-26T22:13:44.607+0900][gc,marking ] GC(1) Concurrent Rebuild Remembered Sets
[2022-04-26T22:13:44.607+0900][gc,marking ] GC(1) Concurrent Rebuild Remembered Sets 0.088ms
[2022-04-26T22:13:44.607+0900][gc,start ] GC(1) Pause Cleanup
[2022-04-26T22:13:44.607+0900][gc ] GC(1) Pause Cleanup 7M->7M(1024M) 0.202ms
[2022-04-26T22:13:44.607+0900][gc,cpu ] GC(1) User=0.00s Sys=0.00s Real=0.00s
[2022-04-26T22:13:44.607+0900][gc,marking ] GC(1) Concurrent Cleanup for Next Mark
[2022-04-26T22:13:44.613+0900][gc,marking ] GC(1) Concurrent Cleanup for Next Mark 6.233ms
[2022-04-26T22:13:44.614+0900][gc ] GC(1) Concurrent Cycle 12.050ms
[2022-04-26T22:13:45.801+0900][gc,start ] GC(2) Pause Young (Normal) (G1 Evacuation Pause)
[2022-04-26T22:13:45.801+0900][gc,task ] GC(2) Using 8 workers of 8 for evacuation
[2022-04-26T22:13:45.809+0900][gc,phases ] GC(2) Pre Evacuate Collection Set: 0.0ms
[2022-04-26T22:13:45.809+0900][gc,phases ] GC(2) Evacuate Collection Set: 6.8ms
[2022-04-26T22:13:45.809+0900][gc,phases ] GC(2) Post Evacuate Collection Set: 0.6ms
[2022-04-26T22:13:45.809+0900][gc,phases ] GC(2) Other: 0.1ms
[2022-04-26T22:13:45.809+0900][gc,heap ] GC(2) Eden regions: 44->0(48)
[2022-04-26T22:13:45.809+0900][gc,heap ] GC(2) Survivor regions: 7->3(7)
[2022-04-26T22:13:45.809+0900][gc,heap ] GC(2) Old regions: 0->7
[2022-04-26T22:13:45.809+0900][gc,heap ] GC(2) Humongous regions: 129->129
[2022-04-26T22:13:45.809+0900][gc,metaspace ] GC(2) Metaspace: 30183K->30183K(1077248K)
[2022-04-26T22:13:45.809+0900][gc ] GC(2) Pause Young (Normal) (G1 Evacuation Pause) 179M->138M(1024M) 7.740ms
[2022-04-26T22:13:45.809+0900][gc,cpu ] GC(2) User=0.04s Sys=0.01s Real=0.00s
[2022-04-26T22:13:46.211+0900][gc,start ] GC(3) Pause Young (Concurrent Start) (Metadata GC Threshold)
[2022-04-26T22:13:46.211+0900][gc,task ] GC(3) Using 8 workers of 8 for evacuation
[2022-04-26T22:13:46.214+0900][gc,phases ] GC(3) Pre Evacuate Collection Set: 0.0ms
[2022-04-26T22:13:46.214+0900][gc,phases ] GC(3) Evacuate Collection Set: 3.0ms
[2022-04-26T22:13:46.214+0900][gc,phases ] GC(3) Post Evacuate Collection Set: 0.3ms
[2022-04-26T22:13:46.214+0900][gc,phases ] GC(3) Other: 0.2ms
[2022-04-26T22:13:46.214+0900][gc,heap ] GC(3) Eden regions: 25->0(48)
[2022-04-26T22:13:46.214+0900][gc,heap ] GC(3) Survivor regions: 3->3(7)
[2022-04-26T22:13:46.214+0900][gc,heap ] GC(3) Old regions: 7->7
[2022-04-26T22:13:46.214+0900][gc,heap ] GC(3) Humongous regions: 129->129
[2022-04-26T22:13:46.214+0900][gc,metaspace ] GC(3) Metaspace: 35153K->35153K(1081344K)
[2022-04-26T22:13:46.214+0900][gc ] GC(3) Pause Young (Concurrent Start) (Metadata GC Threshold) 162M->138M(1024M) 3.584ms
[2022-04-26T22:13:46.214+0900][gc,cpu ] GC(3) User=0.01s Sys=0.00s Real=0.00s
[2022-04-26T22:13:46.214+0900][gc ] GC(4) Concurrent Cycle
[2022-04-26T22:13:46.214+0900][gc,marking ] GC(4) Concurrent Clear Claimed Marks
[2022-04-26T22:13:46.214+0900][gc,marking ] GC(4) Concurrent Clear Claimed Marks 0.034ms
[2022-04-26T22:13:46.215+0900][gc,marking ] GC(4) Concurrent Scan Root Regions
[2022-04-26T22:13:46.216+0900][gc,marking ] GC(4) Concurrent Scan Root Regions 1.399ms
[2022-04-26T22:13:46.216+0900][gc,marking ] GC(4) Concurrent Mark (2.862s)
[2022-04-26T22:13:46.216+0900][gc,marking ] GC(4) Concurrent Mark From Roots
[2022-04-26T22:13:46.216+0900][gc,task ] GC(4) Using 2 workers of 2 for marking
[2022-04-26T22:13:46.220+0900][gc,marking ] GC(4) Concurrent Mark From Roots 4.500ms
[2022-04-26T22:13:46.221+0900][gc,marking ] GC(4) Concurrent Preclean
[2022-04-26T22:13:46.221+0900][gc,marking ] GC(4) Concurrent Preclean 0.093ms
[2022-04-26T22:13:46.221+0900][gc,marking ] GC(4) Concurrent Mark (2.862s, 2.866s) 4.679ms
[2022-04-26T22:13:46.221+0900][gc,start ] GC(4) Pause Remark
[2022-04-26T22:13:46.223+0900][gc,stringtable] GC(4) Cleaned string and symbol table, strings: 11115 processed, 7 removed, symbols: 96957 processed, 26 removed
[2022-04-26T22:13:46.224+0900][gc ] GC(4) Pause Remark 139M->139M(1024M) 2.959ms
[2022-04-26T22:13:46.224+0900][gc,cpu ] GC(4) User=0.01s Sys=0.00s Real=0.00s
[2022-04-26T22:13:46.224+0900][gc,marking ] GC(4) Concurrent Rebuild Remembered Sets
[2022-04-26T22:13:46.227+0900][gc,marking ] GC(4) Concurrent Rebuild Remembered Sets 3.321ms
[2022-04-26T22:13:46.227+0900][gc,start ] GC(4) Pause Cleanup
[2022-04-26T22:13:46.227+0900][gc ] GC(4) Pause Cleanup 139M->139M(1024M) 0.178ms
[2022-04-26T22:13:46.228+0900][gc,cpu ] GC(4) User=0.00s Sys=0.00s Real=0.00s
[2022-04-26T22:13:46.228+0900][gc,marking ] GC(4) Concurrent Cleanup for Next Mark
[2022-04-26T22:13:46.234+0900][gc,marking ] GC(4) Concurrent Cleanup for Next Mark 6.322ms
[2022-04-26T22:13:46.234+0900][gc ] GC(4) Concurrent Cycle 19.521ms
[2022-04-26T22:14:15.614+0900][gc,start ] GC(5) Pause Young (Normal) (G1 Evacuation Pause)
[2022-04-26T22:14:15.614+0900][gc,task ] GC(5) Using 8 workers of 8 for evacuation
[2022-04-26T22:14:15.620+0900][gc,phases ] GC(5) Pre Evacuate Collection Set: 0.1ms
[2022-04-26T22:14:15.620+0900][gc,phases ] GC(5) Evacuate Collection Set: 5.0ms
[2022-04-26T22:14:15.620+0900][gc,phases ] GC(5) Post Evacuate Collection Set: 0.5ms
[2022-04-26T22:14:15.620+0900][gc,phases ] GC(5) Other: 0.3ms
[2022-04-26T22:14:15.620+0900][gc,heap ] GC(5) Eden regions: 48->0(44)
[2022-04-26T22:14:15.620+0900][gc,heap ] GC(5) Survivor regions: 3->7(7)
[2022-04-26T22:14:15.620+0900][gc,heap ] GC(5) Old regions: 7->7
[2022-04-26T22:14:15.620+0900][gc,heap ] GC(5) Humongous regions: 129->129
[2022-04-26T22:14:15.620+0900][gc,metaspace ] GC(5) Metaspace: 43644K->43644K(1089536K)
[2022-04-26T22:14:15.620+0900][gc ] GC(5) Pause Young (Normal) (G1 Evacuation Pause) 186M->142M(1024M) 5.961ms
[2022-04-26T22:14:15.620+0900][gc,cpu ] GC(5) User=0.04s Sys=0.01s Real=0.01s
[2022-04-26T22:23:28.271+0900][gc,start ] GC(6) Pause Young (Normal) (G1 Evacuation Pause)
[2022-04-26T22:23:28.271+0900][gc,task ] GC(6) Using 8 workers of 8 for evacuation
[2022-04-26T22:23:28.279+0900][gc,phases ] GC(6) Pre Evacuate Collection Set: 0.0ms
[2022-04-26T22:23:28.279+0900][gc,phases ] GC(6) Evacuate Collection Set: 6.9ms
[2022-04-26T22:23:28.279+0900][gc,phases ] GC(6) Post Evacuate Collection Set: 0.8ms
[2022-04-26T22:23:28.279+0900][gc,phases ] GC(6) Other: 0.2ms
[2022-04-26T22:23:28.279+0900][gc,heap ] GC(6) Eden regions: 44->0(48)
[2022-04-26T22:23:28.279+0900][gc,heap ] GC(6) Survivor regions: 7->3(7)
[2022-04-26T22:23:28.279+0900][gc,heap ] GC(6) Old regions: 7->14
[2022-04-26T22:23:28.279+0900][gc,heap ] GC(6) Humongous regions: 129->129
[2022-04-26T22:23:28.279+0900][gc,metaspace ] GC(6) Metaspace: 49030K->49030K(1093632K)
[2022-04-26T22:23:28.279+0900][gc ] GC(6) Pause Young (Normal) (G1 Evacuation Pause) 186M->144M(1024M) 8.130ms
[2022-04-26T22:23:28.279+0900][gc,cpu ] GC(6) User=0.05s Sys=0.01s Real=0.00s
[2022-04-26T22:30:54.551+0900][gc,start ] GC(7) Pause Young (Normal) (G1 Evacuation Pause)
[2022-04-26T22:30:54.552+0900][gc,task ] GC(7) Using 8 workers of 8 for evacuation
[2022-04-26T22:30:54.558+0900][gc,phases ] GC(7) Pre Evacuate Collection Set: 0.0ms
[2022-04-26T22:30:54.558+0900][gc,phases ] GC(7) Evacuate Collection Set: 5.5ms
[2022-04-26T22:30:54.558+0900][gc,phases ] GC(7) Post Evacuate Collection Set: 0.7ms
[2022-04-26T22:30:54.558+0900][gc,phases ] GC(7) Other: 0.4ms
[2022-04-26T22:30:54.558+0900][gc,heap ] GC(7) Eden regions: 48->0(45)
[2022-04-26T22:30:54.558+0900][gc,heap ] GC(7) Survivor regions: 3->6(7)
[2022-04-26T22:30:54.558+0900][gc,heap ] GC(7) Old regions: 14->14
[2022-04-26T22:30:54.558+0900][gc,heap ] GC(7) Humongous regions: 129->129
[2022-04-26T22:30:54.558+0900][gc,metaspace ] GC(7) Metaspace: 51505K->51505K(1095680K)
[2022-04-26T22:30:54.558+0900][gc ] GC(7) Pause Young (Normal) (G1 Evacuation Pause) 192M->147M(1024M) 6.739ms
[2022-04-26T22:30:54.558+0900][gc,cpu ] GC(7) User=0.04s Sys=0.00s Real=0.00s

2
thirdparty/kafka_2.13-3.1.0/logs/log-cleaner.log vendored Normal file
View File

@@ -0,0 +1,2 @@
[2022-04-26 22:13:45,623] INFO Starting the log cleaner (kafka.log.LogCleaner)
[2022-04-26 22:13:45,721] INFO [kafka-log-cleaner-thread-0]: Starting (kafka.log.LogCleaner)

1083
thirdparty/kafka_2.13-3.1.0/logs/server.log vendored Normal file
View File

File diff suppressed because one or more lines are too long

172
thirdparty/kafka_2.13-3.1.0/logs/state-change.log vendored Normal file
View File

@@ -0,0 +1,172 @@
[2022-04-26 22:13:46,769] INFO [Controller id=0 epoch=1] Sending UpdateMetadata request to brokers HashSet(0) for 0 partitions (state.change.logger)
[2022-04-26 22:17:10,880] INFO [Controller id=0 epoch=1] Changed partition roy-topic-0 state from NonExistentPartition to NewPartition with assigned replicas 0 (state.change.logger)
[2022-04-26 22:17:10,880] INFO [Controller id=0 epoch=1] Sending UpdateMetadata request to brokers HashSet() for 0 partitions (state.change.logger)
[2022-04-26 22:17:10,883] INFO [Controller id=0 epoch=1] Sending UpdateMetadata request to brokers HashSet() for 0 partitions (state.change.logger)
[2022-04-26 22:17:10,934] INFO [Controller id=0 epoch=1] Changed partition roy-topic-0 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=0, leaderEpoch=0, isr=List(0), zkVersion=0) (state.change.logger)
[2022-04-26 22:17:10,935] INFO [Controller id=0 epoch=1] Sending LeaderAndIsr request to broker 0 with 1 become-leader and 0 become-follower partitions (state.change.logger)
[2022-04-26 22:17:10,937] INFO [Controller id=0 epoch=1] Sending UpdateMetadata request to brokers HashSet(0) for 1 partitions (state.change.logger)
[2022-04-26 22:17:10,938] INFO [Controller id=0 epoch=1] Sending UpdateMetadata request to brokers HashSet() for 0 partitions (state.change.logger)
[2022-04-26 22:17:10,941] INFO [Broker id=0] Handling LeaderAndIsr request correlationId 1 from controller 0 for 1 partitions (state.change.logger)
[2022-04-26 22:17:10,963] INFO [Broker id=0] Stopped fetchers as part of LeaderAndIsr request correlationId 1 from controller 0 epoch 1 as part of the become-leader transition for 1 partitions (state.change.logger)
[2022-04-26 22:17:11,064] INFO [Broker id=0] Leader roy-topic-0 starts at leader epoch 0 from offset 0 with high watermark 0 ISR [0] addingReplicas [] removingReplicas []. Previous leader epoch was -1. (state.change.logger)
[2022-04-26 22:17:11,087] INFO [Broker id=0] Finished LeaderAndIsr request in 148ms correlationId 1 from controller 0 for 1 partitions (state.change.logger)
[2022-04-26 22:17:11,096] INFO [Broker id=0] Add 1 partitions and deleted 0 partitions from metadata cache in response to UpdateMetadata request sent by controller 0 epoch 1 with correlation id 2 (state.change.logger)
[2022-04-26 22:23:26,455] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-22 state from NonExistentPartition to NewPartition with assigned replicas 0 (state.change.logger)
[2022-04-26 22:23:26,455] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-30 state from NonExistentPartition to NewPartition with assigned replicas 0 (state.change.logger)
[2022-04-26 22:23:26,455] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-25 state from NonExistentPartition to NewPartition with assigned replicas 0 (state.change.logger)
[2022-04-26 22:23:26,455] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-35 state from NonExistentPartition to NewPartition with assigned replicas 0 (state.change.logger)
[2022-04-26 22:23:26,455] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-37 state from NonExistentPartition to NewPartition with assigned replicas 0 (state.change.logger)
[2022-04-26 22:23:26,455] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-38 state from NonExistentPartition to NewPartition with assigned replicas 0 (state.change.logger)
[2022-04-26 22:23:26,455] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-13 state from NonExistentPartition to NewPartition with assigned replicas 0 (state.change.logger)
[2022-04-26 22:23:26,455] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-8 state from NonExistentPartition to NewPartition with assigned replicas 0 (state.change.logger)
[2022-04-26 22:23:26,455] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-21 state from NonExistentPartition to NewPartition with assigned replicas 0 (state.change.logger)
[2022-04-26 22:23:26,455] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-4 state from NonExistentPartition to NewPartition with assigned replicas 0 (state.change.logger)
[2022-04-26 22:23:26,455] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-27 state from NonExistentPartition to NewPartition with assigned replicas 0 (state.change.logger)
[2022-04-26 22:23:26,455] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-7 state from NonExistentPartition to NewPartition with assigned replicas 0 (state.change.logger)
[2022-04-26 22:23:26,455] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-9 state from NonExistentPartition to NewPartition with assigned replicas 0 (state.change.logger)
[2022-04-26 22:23:26,456] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-46 state from NonExistentPartition to NewPartition with assigned replicas 0 (state.change.logger)
[2022-04-26 22:23:26,456] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-41 state from NonExistentPartition to NewPartition with assigned replicas 0 (state.change.logger)
[2022-04-26 22:23:26,456] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-33 state from NonExistentPartition to NewPartition with assigned replicas 0 (state.change.logger)
[2022-04-26 22:23:26,456] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-23 state from NonExistentPartition to NewPartition with assigned replicas 0 (state.change.logger)
[2022-04-26 22:23:26,456] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-49 state from NonExistentPartition to NewPartition with assigned replicas 0 (state.change.logger)
[2022-04-26 22:23:26,456] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-47 state from NonExistentPartition to NewPartition with assigned replicas 0 (state.change.logger)
[2022-04-26 22:23:26,456] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-16 state from NonExistentPartition to NewPartition with assigned replicas 0 (state.change.logger)
[2022-04-26 22:23:26,456] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-28 state from NonExistentPartition to NewPartition with assigned replicas 0 (state.change.logger)
[2022-04-26 22:23:26,456] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-31 state from NonExistentPartition to NewPartition with assigned replicas 0 (state.change.logger)
[2022-04-26 22:23:26,456] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-36 state from NonExistentPartition to NewPartition with assigned replicas 0 (state.change.logger)
[2022-04-26 22:23:26,456] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-42 state from NonExistentPartition to NewPartition with assigned replicas 0 (state.change.logger)
[2022-04-26 22:23:26,456] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-3 state from NonExistentPartition to NewPartition with assigned replicas 0 (state.change.logger)
[2022-04-26 22:23:26,456] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-18 state from NonExistentPartition to NewPartition with assigned replicas 0 (state.change.logger)
[2022-04-26 22:23:26,456] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-15 state from NonExistentPartition to NewPartition with assigned replicas 0 (state.change.logger)
[2022-04-26 22:23:26,456] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-24 state from NonExistentPartition to NewPartition with assigned replicas 0 (state.change.logger)
[2022-04-26 22:23:26,456] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-17 state from NonExistentPartition to NewPartition with assigned replicas 0 (state.change.logger)
[2022-04-26 22:23:26,456] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-48 state from NonExistentPartition to NewPartition with assigned replicas 0 (state.change.logger)
[2022-04-26 22:23:26,456] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-19 state from NonExistentPartition to NewPartition with assigned replicas 0 (state.change.logger)
[2022-04-26 22:23:26,457] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-11 state from NonExistentPartition to NewPartition with assigned replicas 0 (state.change.logger)
[2022-04-26 22:23:26,457] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-2 state from NonExistentPartition to NewPartition with assigned replicas 0 (state.change.logger)
[2022-04-26 22:23:26,457] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-43 state from NonExistentPartition to NewPartition with assigned replicas 0 (state.change.logger)
[2022-04-26 22:23:26,457] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-6 state from NonExistentPartition to NewPartition with assigned replicas 0 (state.change.logger)
[2022-04-26 22:23:26,457] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-14 state from NonExistentPartition to NewPartition with assigned replicas 0 (state.change.logger)
[2022-04-26 22:23:26,457] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-20 state from NonExistentPartition to NewPartition with assigned replicas 0 (state.change.logger)
[2022-04-26 22:23:26,457] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-0 state from NonExistentPartition to NewPartition with assigned replicas 0 (state.change.logger)
[2022-04-26 22:23:26,457] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-44 state from NonExistentPartition to NewPartition with assigned replicas 0 (state.change.logger)
[2022-04-26 22:23:26,457] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-39 state from NonExistentPartition to NewPartition with assigned replicas 0 (state.change.logger)
[2022-04-26 22:23:26,457] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-12 state from NonExistentPartition to NewPartition with assigned replicas 0 (state.change.logger)
[2022-04-26 22:23:26,457] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-45 state from NonExistentPartition to NewPartition with assigned replicas 0 (state.change.logger)
[2022-04-26 22:23:26,457] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-1 state from NonExistentPartition to NewPartition with assigned replicas 0 (state.change.logger)
[2022-04-26 22:23:26,457] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-5 state from NonExistentPartition to NewPartition with assigned replicas 0 (state.change.logger)
[2022-04-26 22:23:26,457] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-26 state from NonExistentPartition to NewPartition with assigned replicas 0 (state.change.logger)
[2022-04-26 22:23:26,457] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-29 state from NonExistentPartition to NewPartition with assigned replicas 0 (state.change.logger)
[2022-04-26 22:23:26,457] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-34 state from NonExistentPartition to NewPartition with assigned replicas 0 (state.change.logger)
[2022-04-26 22:23:26,457] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-10 state from NonExistentPartition to NewPartition with assigned replicas 0 (state.change.logger)
[2022-04-26 22:23:26,457] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-32 state from NonExistentPartition to NewPartition with assigned replicas 0 (state.change.logger)
[2022-04-26 22:23:26,457] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-40 state from NonExistentPartition to NewPartition with assigned replicas 0 (state.change.logger)
[2022-04-26 22:23:26,458] INFO [Controller id=0 epoch=1] Sending UpdateMetadata request to brokers HashSet() for 0 partitions (state.change.logger)
[2022-04-26 22:23:26,459] INFO [Controller id=0 epoch=1] Sending UpdateMetadata request to brokers HashSet() for 0 partitions (state.change.logger)
[2022-04-26 22:23:26,736] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-22 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=0, leaderEpoch=0, isr=List(0), zkVersion=0) (state.change.logger)
[2022-04-26 22:23:26,737] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-30 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=0, leaderEpoch=0, isr=List(0), zkVersion=0) (state.change.logger)
[2022-04-26 22:23:26,737] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-25 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=0, leaderEpoch=0, isr=List(0), zkVersion=0) (state.change.logger)
[2022-04-26 22:23:26,737] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-35 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=0, leaderEpoch=0, isr=List(0), zkVersion=0) (state.change.logger)
[2022-04-26 22:23:26,737] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-37 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=0, leaderEpoch=0, isr=List(0), zkVersion=0) (state.change.logger)
[2022-04-26 22:23:26,737] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-38 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=0, leaderEpoch=0, isr=List(0), zkVersion=0) (state.change.logger)
[2022-04-26 22:23:26,737] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-13 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=0, leaderEpoch=0, isr=List(0), zkVersion=0) (state.change.logger)
[2022-04-26 22:23:26,737] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-8 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=0, leaderEpoch=0, isr=List(0), zkVersion=0) (state.change.logger)
[2022-04-26 22:23:26,737] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-21 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=0, leaderEpoch=0, isr=List(0), zkVersion=0) (state.change.logger)
[2022-04-26 22:23:26,737] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-4 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=0, leaderEpoch=0, isr=List(0), zkVersion=0) (state.change.logger)
[2022-04-26 22:23:26,737] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-27 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=0, leaderEpoch=0, isr=List(0), zkVersion=0) (state.change.logger)
[2022-04-26 22:23:26,737] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-7 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=0, leaderEpoch=0, isr=List(0), zkVersion=0) (state.change.logger)
[2022-04-26 22:23:26,737] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-9 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=0, leaderEpoch=0, isr=List(0), zkVersion=0) (state.change.logger)
[2022-04-26 22:23:26,737] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-46 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=0, leaderEpoch=0, isr=List(0), zkVersion=0) (state.change.logger)
[2022-04-26 22:23:26,737] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-41 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=0, leaderEpoch=0, isr=List(0), zkVersion=0) (state.change.logger)
[2022-04-26 22:23:26,737] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-33 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=0, leaderEpoch=0, isr=List(0), zkVersion=0) (state.change.logger)
[2022-04-26 22:23:26,737] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-23 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=0, leaderEpoch=0, isr=List(0), zkVersion=0) (state.change.logger)
[2022-04-26 22:23:26,737] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-49 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=0, leaderEpoch=0, isr=List(0), zkVersion=0) (state.change.logger)
[2022-04-26 22:23:26,737] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-47 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=0, leaderEpoch=0, isr=List(0), zkVersion=0) (state.change.logger)
[2022-04-26 22:23:26,737] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-16 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=0, leaderEpoch=0, isr=List(0), zkVersion=0) (state.change.logger)
[2022-04-26 22:23:26,737] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-28 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=0, leaderEpoch=0, isr=List(0), zkVersion=0) (state.change.logger)
[2022-04-26 22:23:26,737] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-31 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=0, leaderEpoch=0, isr=List(0), zkVersion=0) (state.change.logger)
[2022-04-26 22:23:26,737] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-36 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=0, leaderEpoch=0, isr=List(0), zkVersion=0) (state.change.logger)
[2022-04-26 22:23:26,737] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-42 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=0, leaderEpoch=0, isr=List(0), zkVersion=0) (state.change.logger)
[2022-04-26 22:23:26,737] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-3 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=0, leaderEpoch=0, isr=List(0), zkVersion=0) (state.change.logger)
[2022-04-26 22:23:26,737] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-18 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=0, leaderEpoch=0, isr=List(0), zkVersion=0) (state.change.logger)
[2022-04-26 22:23:26,737] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-15 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=0, leaderEpoch=0, isr=List(0), zkVersion=0) (state.change.logger)
[2022-04-26 22:23:26,737] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-24 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=0, leaderEpoch=0, isr=List(0), zkVersion=0) (state.change.logger)
[2022-04-26 22:23:26,737] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-17 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=0, leaderEpoch=0, isr=List(0), zkVersion=0) (state.change.logger)
[2022-04-26 22:23:26,738] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-48 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=0, leaderEpoch=0, isr=List(0), zkVersion=0) (state.change.logger)
[2022-04-26 22:23:26,738] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-19 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=0, leaderEpoch=0, isr=List(0), zkVersion=0) (state.change.logger)
[2022-04-26 22:23:26,738] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-11 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=0, leaderEpoch=0, isr=List(0), zkVersion=0) (state.change.logger)
[2022-04-26 22:23:26,738] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-2 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=0, leaderEpoch=0, isr=List(0), zkVersion=0) (state.change.logger)
[2022-04-26 22:23:26,738] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-43 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=0, leaderEpoch=0, isr=List(0), zkVersion=0) (state.change.logger)
[2022-04-26 22:23:26,738] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-6 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=0, leaderEpoch=0, isr=List(0), zkVersion=0) (state.change.logger)
[2022-04-26 22:23:26,738] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-14 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=0, leaderEpoch=0, isr=List(0), zkVersion=0) (state.change.logger)
[2022-04-26 22:23:26,738] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-20 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=0, leaderEpoch=0, isr=List(0), zkVersion=0) (state.change.logger)
[2022-04-26 22:23:26,738] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-0 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=0, leaderEpoch=0, isr=List(0), zkVersion=0) (state.change.logger)
[2022-04-26 22:23:26,738] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-44 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=0, leaderEpoch=0, isr=List(0), zkVersion=0) (state.change.logger)
[2022-04-26 22:23:26,738] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-39 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=0, leaderEpoch=0, isr=List(0), zkVersion=0) (state.change.logger)
[2022-04-26 22:23:26,738] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-12 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=0, leaderEpoch=0, isr=List(0), zkVersion=0) (state.change.logger)
[2022-04-26 22:23:26,738] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-45 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=0, leaderEpoch=0, isr=List(0), zkVersion=0) (state.change.logger)
[2022-04-26 22:23:26,738] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-1 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=0, leaderEpoch=0, isr=List(0), zkVersion=0) (state.change.logger)
[2022-04-26 22:23:26,738] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-5 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=0, leaderEpoch=0, isr=List(0), zkVersion=0) (state.change.logger)
[2022-04-26 22:23:26,738] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-26 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=0, leaderEpoch=0, isr=List(0), zkVersion=0) (state.change.logger)
[2022-04-26 22:23:26,738] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-29 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=0, leaderEpoch=0, isr=List(0), zkVersion=0) (state.change.logger)
[2022-04-26 22:23:26,738] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-34 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=0, leaderEpoch=0, isr=List(0), zkVersion=0) (state.change.logger)
[2022-04-26 22:23:26,738] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-10 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=0, leaderEpoch=0, isr=List(0), zkVersion=0) (state.change.logger)
[2022-04-26 22:23:26,738] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-32 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=0, leaderEpoch=0, isr=List(0), zkVersion=0) (state.change.logger)
[2022-04-26 22:23:26,738] INFO [Controller id=0 epoch=1] Changed partition __consumer_offsets-40 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=0, leaderEpoch=0, isr=List(0), zkVersion=0) (state.change.logger)
[2022-04-26 22:23:26,738] INFO [Controller id=0 epoch=1] Sending LeaderAndIsr request to broker 0 with 50 become-leader and 0 become-follower partitions (state.change.logger)
[2022-04-26 22:23:26,739] INFO [Controller id=0 epoch=1] Sending UpdateMetadata request to brokers HashSet(0) for 50 partitions (state.change.logger)
[2022-04-26 22:23:26,740] INFO [Controller id=0 epoch=1] Sending UpdateMetadata request to brokers HashSet() for 0 partitions (state.change.logger)
[2022-04-26 22:23:26,740] INFO [Broker id=0] Handling LeaderAndIsr request correlationId 3 from controller 0 for 50 partitions (state.change.logger)
[2022-04-26 22:23:26,765] INFO [Broker id=0] Stopped fetchers as part of LeaderAndIsr request correlationId 3 from controller 0 epoch 1 as part of the become-leader transition for 50 partitions (state.change.logger)
[2022-04-26 22:23:26,772] INFO [Broker id=0] Leader __consumer_offsets-3 starts at leader epoch 0 from offset 0 with high watermark 0 ISR [0] addingReplicas [] removingReplicas []. Previous leader epoch was -1. (state.change.logger)
[2022-04-26 22:23:26,795] INFO [Broker id=0] Leader __consumer_offsets-18 starts at leader epoch 0 from offset 0 with high watermark 0 ISR [0] addingReplicas [] removingReplicas []. Previous leader epoch was -1. (state.change.logger)
[2022-04-26 22:23:26,822] INFO [Broker id=0] Leader __consumer_offsets-41 starts at leader epoch 0 from offset 0 with high watermark 0 ISR [0] addingReplicas [] removingReplicas []. Previous leader epoch was -1. (state.change.logger)
[2022-04-26 22:23:26,845] INFO [Broker id=0] Leader __consumer_offsets-10 starts at leader epoch 0 from offset 0 with high watermark 0 ISR [0] addingReplicas [] removingReplicas []. Previous leader epoch was -1. (state.change.logger)
[2022-04-26 22:23:26,868] INFO [Broker id=0] Leader __consumer_offsets-33 starts at leader epoch 0 from offset 0 with high watermark 0 ISR [0] addingReplicas [] removingReplicas []. Previous leader epoch was -1. (state.change.logger)
[2022-04-26 22:23:26,891] INFO [Broker id=0] Leader __consumer_offsets-48 starts at leader epoch 0 from offset 0 with high watermark 0 ISR [0] addingReplicas [] removingReplicas []. Previous leader epoch was -1. (state.change.logger)
[2022-04-26 22:23:26,918] INFO [Broker id=0] Leader __consumer_offsets-19 starts at leader epoch 0 from offset 0 with high watermark 0 ISR [0] addingReplicas [] removingReplicas []. Previous leader epoch was -1. (state.change.logger)
[2022-04-26 22:23:26,947] INFO [Broker id=0] Leader __consumer_offsets-34 starts at leader epoch 0 from offset 0 with high watermark 0 ISR [0] addingReplicas [] removingReplicas []. Previous leader epoch was -1. (state.change.logger)
[2022-04-26 22:23:26,970] INFO [Broker id=0] Leader __consumer_offsets-4 starts at leader epoch 0 from offset 0 with high watermark 0 ISR [0] addingReplicas [] removingReplicas []. Previous leader epoch was -1. (state.change.logger)
[2022-04-26 22:23:26,997] INFO [Broker id=0] Leader __consumer_offsets-11 starts at leader epoch 0 from offset 0 with high watermark 0 ISR [0] addingReplicas [] removingReplicas []. Previous leader epoch was -1. (state.change.logger)
[2022-04-26 22:23:27,020] INFO [Broker id=0] Leader __consumer_offsets-26 starts at leader epoch 0 from offset 0 with high watermark 0 ISR [0] addingReplicas [] removingReplicas []. Previous leader epoch was -1. (state.change.logger)
[2022-04-26 22:23:27,045] INFO [Broker id=0] Leader __consumer_offsets-49 starts at leader epoch 0 from offset 0 with high watermark 0 ISR [0] addingReplicas [] removingReplicas []. Previous leader epoch was -1. (state.change.logger)
[2022-04-26 22:23:27,070] INFO [Broker id=0] Leader __consumer_offsets-39 starts at leader epoch 0 from offset 0 with high watermark 0 ISR [0] addingReplicas [] removingReplicas []. Previous leader epoch was -1. (state.change.logger)
[2022-04-26 22:23:27,096] INFO [Broker id=0] Leader __consumer_offsets-9 starts at leader epoch 0 from offset 0 with high watermark 0 ISR [0] addingReplicas [] removingReplicas []. Previous leader epoch was -1. (state.change.logger)
[2022-04-26 22:23:27,121] INFO [Broker id=0] Leader __consumer_offsets-24 starts at leader epoch 0 from offset 0 with high watermark 0 ISR [0] addingReplicas [] removingReplicas []. Previous leader epoch was -1. (state.change.logger)
[2022-04-26 22:23:27,146] INFO [Broker id=0] Leader __consumer_offsets-31 starts at leader epoch 0 from offset 0 with high watermark 0 ISR [0] addingReplicas [] removingReplicas []. Previous leader epoch was -1. (state.change.logger)
[2022-04-26 22:23:27,172] INFO [Broker id=0] Leader __consumer_offsets-46 starts at leader epoch 0 from offset 0 with high watermark 0 ISR [0] addingReplicas [] removingReplicas []. Previous leader epoch was -1. (state.change.logger)
[2022-04-26 22:23:27,195] INFO [Broker id=0] Leader __consumer_offsets-1 starts at leader epoch 0 from offset 0 with high watermark 0 ISR [0] addingReplicas [] removingReplicas []. Previous leader epoch was -1. (state.change.logger)
[2022-04-26 22:23:27,218] INFO [Broker id=0] Leader __consumer_offsets-16 starts at leader epoch 0 from offset 0 with high watermark 0 ISR [0] addingReplicas [] removingReplicas []. Previous leader epoch was -1. (state.change.logger)
[2022-04-26 22:23:27,242] INFO [Broker id=0] Leader __consumer_offsets-2 starts at leader epoch 0 from offset 0 with high watermark 0 ISR [0] addingReplicas [] removingReplicas []. Previous leader epoch was -1. (state.change.logger)
[2022-04-26 22:23:27,268] INFO [Broker id=0] Leader __consumer_offsets-25 starts at leader epoch 0 from offset 0 with high watermark 0 ISR [0] addingReplicas [] removingReplicas []. Previous leader epoch was -1. (state.change.logger)
[2022-04-26 22:23:27,292] INFO [Broker id=0] Leader __consumer_offsets-40 starts at leader epoch 0 from offset 0 with high watermark 0 ISR [0] addingReplicas [] removingReplicas []. Previous leader epoch was -1. (state.change.logger)
[2022-04-26 22:23:27,320] INFO [Broker id=0] Leader __consumer_offsets-47 starts at leader epoch 0 from offset 0 with high watermark 0 ISR [0] addingReplicas [] removingReplicas []. Previous leader epoch was -1. (state.change.logger)
[2022-04-26 22:23:27,341] INFO [Broker id=0] Leader __consumer_offsets-17 starts at leader epoch 0 from offset 0 with high watermark 0 ISR [0] addingReplicas [] removingReplicas []. Previous leader epoch was -1. (state.change.logger)
[2022-04-26 22:23:27,364] INFO [Broker id=0] Leader __consumer_offsets-32 starts at leader epoch 0 from offset 0 with high watermark 0 ISR [0] addingReplicas [] removingReplicas []. Previous leader epoch was -1. (state.change.logger)
[2022-04-26 22:23:27,387] INFO [Broker id=0] Leader __consumer_offsets-37 starts at leader epoch 0 from offset 0 with high watermark 0 ISR [0] addingReplicas [] removingReplicas []. Previous leader epoch was -1. (state.change.logger)
[2022-04-26 22:23:27,413] INFO [Broker id=0] Leader __consumer_offsets-7 starts at leader epoch 0 from offset 0 with high watermark 0 ISR [0] addingReplicas [] removingReplicas []. Previous leader epoch was -1. (state.change.logger)
[2022-04-26 22:23:27,439] INFO [Broker id=0] Leader __consumer_offsets-22 starts at leader epoch 0 from offset 0 with high watermark 0 ISR [0] addingReplicas [] removingReplicas []. Previous leader epoch was -1. (state.change.logger)
[2022-04-26 22:23:27,461] INFO [Broker id=0] Leader __consumer_offsets-29 starts at leader epoch 0 from offset 0 with high watermark 0 ISR [0] addingReplicas [] removingReplicas []. Previous leader epoch was -1. (state.change.logger)
[2022-04-26 22:23:27,486] INFO [Broker id=0] Leader __consumer_offsets-44 starts at leader epoch 0 from offset 0 with high watermark 0 ISR [0] addingReplicas [] removingReplicas []. Previous leader epoch was -1. (state.change.logger)
[2022-04-26 22:23:27,513] INFO [Broker id=0] Leader __consumer_offsets-14 starts at leader epoch 0 from offset 0 with high watermark 0 ISR [0] addingReplicas [] removingReplicas []. Previous leader epoch was -1. (state.change.logger)
[2022-04-26 22:23:27,544] INFO [Broker id=0] Leader __consumer_offsets-23 starts at leader epoch 0 from offset 0 with high watermark 0 ISR [0] addingReplicas [] removingReplicas []. Previous leader epoch was -1. (state.change.logger)
[2022-04-26 22:23:27,567] INFO [Broker id=0] Leader __consumer_offsets-38 starts at leader epoch 0 from offset 0 with high watermark 0 ISR [0] addingReplicas [] removingReplicas []. Previous leader epoch was -1. (state.change.logger)
[2022-04-26 22:23:27,596] INFO [Broker id=0] Leader __consumer_offsets-8 starts at leader epoch 0 from offset 0 with high watermark 0 ISR [0] addingReplicas [] removingReplicas []. Previous leader epoch was -1. (state.change.logger)
[2022-04-26 22:23:27,621] INFO [Broker id=0] Leader __consumer_offsets-45 starts at leader epoch 0 from offset 0 with high watermark 0 ISR [0] addingReplicas [] removingReplicas []. Previous leader epoch was -1. (state.change.logger)
[2022-04-26 22:23:27,647] INFO [Broker id=0] Leader __consumer_offsets-15 starts at leader epoch 0 from offset 0 with high watermark 0 ISR [0] addingReplicas [] removingReplicas []. Previous leader epoch was -1. (state.change.logger)
[2022-04-26 22:23:27,677] INFO [Broker id=0] Leader __consumer_offsets-30 starts at leader epoch 0 from offset 0 with high watermark 0 ISR [0] addingReplicas [] removingReplicas []. Previous leader epoch was -1. (state.change.logger)
[2022-04-26 22:23:27,702] INFO [Broker id=0] Leader __consumer_offsets-0 starts at leader epoch 0 from offset 0 with high watermark 0 ISR [0] addingReplicas [] removingReplicas []. Previous leader epoch was -1. (state.change.logger)
[2022-04-26 22:23:27,731] INFO [Broker id=0] Leader __consumer_offsets-35 starts at leader epoch 0 from offset 0 with high watermark 0 ISR [0] addingReplicas [] removingReplicas []. Previous leader epoch was -1. (state.change.logger)
[2022-04-26 22:23:27,760] INFO [Broker id=0] Leader __consumer_offsets-5 starts at leader epoch 0 from offset 0 with high watermark 0 ISR [0] addingReplicas [] removingReplicas []. Previous leader epoch was -1. (state.change.logger)
[2022-04-26 22:23:27,783] INFO [Broker id=0] Leader __consumer_offsets-20 starts at leader epoch 0 from offset 0 with high watermark 0 ISR [0] addingReplicas [] removingReplicas []. Previous leader epoch was -1. (state.change.logger)
[2022-04-26 22:23:27,809] INFO [Broker id=0] Leader __consumer_offsets-27 starts at leader epoch 0 from offset 0 with high watermark 0 ISR [0] addingReplicas [] removingReplicas []. Previous leader epoch was -1. (state.change.logger)
[2022-04-26 22:23:27,835] INFO [Broker id=0] Leader __consumer_offsets-42 starts at leader epoch 0 from offset 0 with high watermark 0 ISR [0] addingReplicas [] removingReplicas []. Previous leader epoch was -1. (state.change.logger)
[2022-04-26 22:23:27,862] INFO [Broker id=0] Leader __consumer_offsets-12 starts at leader epoch 0 from offset 0 with high watermark 0 ISR [0] addingReplicas [] removingReplicas []. Previous leader epoch was -1. (state.change.logger)
[2022-04-26 22:23:27,888] INFO [Broker id=0] Leader __consumer_offsets-21 starts at leader epoch 0 from offset 0 with high watermark 0 ISR [0] addingReplicas [] removingReplicas []. Previous leader epoch was -1. (state.change.logger)
[2022-04-26 22:23:27,913] INFO [Broker id=0] Leader __consumer_offsets-36 starts at leader epoch 0 from offset 0 with high watermark 0 ISR [0] addingReplicas [] removingReplicas []. Previous leader epoch was -1. (state.change.logger)
[2022-04-26 22:23:27,940] INFO [Broker id=0] Leader __consumer_offsets-6 starts at leader epoch 0 from offset 0 with high watermark 0 ISR [0] addingReplicas [] removingReplicas []. Previous leader epoch was -1. (state.change.logger)
[2022-04-26 22:23:27,966] INFO [Broker id=0] Leader __consumer_offsets-43 starts at leader epoch 0 from offset 0 with high watermark 0 ISR [0] addingReplicas [] removingReplicas []. Previous leader epoch was -1. (state.change.logger)
[2022-04-26 22:23:27,992] INFO [Broker id=0] Leader __consumer_offsets-13 starts at leader epoch 0 from offset 0 with high watermark 0 ISR [0] addingReplicas [] removingReplicas []. Previous leader epoch was -1. (state.change.logger)
[2022-04-26 22:23:28,019] INFO [Broker id=0] Leader __consumer_offsets-28 starts at leader epoch 0 from offset 0 with high watermark 0 ISR [0] addingReplicas [] removingReplicas []. Previous leader epoch was -1. (state.change.logger)
[2022-04-26 22:23:28,047] INFO [Broker id=0] Finished LeaderAndIsr request in 1307ms correlationId 3 from controller 0 for 50 partitions (state.change.logger)
[2022-04-26 22:23:28,050] INFO [Broker id=0] Add 50 partitions and deleted 0 partitions from metadata cache in response to UpdateMetadata request sent by controller 0 epoch 1 with correlation id 4 (state.change.logger)

16
thirdparty/kafka_2.13-3.1.0/logs/zookeeper-gc.log vendored Normal file
View File

@@ -0,0 +1,16 @@
[2022-04-26T22:11:28.578+0900][gc,heap] Heap region size: 1M
[2022-04-26T22:11:28.583+0900][gc ] Using G1
[2022-04-26T22:11:28.583+0900][gc,heap,coops] Heap address: 0x00000007e0000000, size: 512 MB, Compressed Oops mode: Zero based, Oop shift amount: 3
[2022-04-26T22:11:29.431+0900][gc,start ] GC(0) Pause Young (Normal) (G1 Evacuation Pause)
[2022-04-26T22:11:29.432+0900][gc,task ] GC(0) Using 8 workers of 8 for evacuation
[2022-04-26T22:11:29.437+0900][gc,phases ] GC(0) Pre Evacuate Collection Set: 0.0ms
[2022-04-26T22:11:29.437+0900][gc,phases ] GC(0) Evacuate Collection Set: 4.7ms
[2022-04-26T22:11:29.437+0900][gc,phases ] GC(0) Post Evacuate Collection Set: 0.4ms
[2022-04-26T22:11:29.437+0900][gc,phases ] GC(0) Other: 1.0ms
[2022-04-26T22:11:29.437+0900][gc,heap ] GC(0) Eden regions: 25->0(21)
[2022-04-26T22:11:29.437+0900][gc,heap ] GC(0) Survivor regions: 0->4(4)
[2022-04-26T22:11:29.437+0900][gc,heap ] GC(0) Old regions: 0->4
[2022-04-26T22:11:29.437+0900][gc,heap ] GC(0) Humongous regions: 0->0
[2022-04-26T22:11:29.437+0900][gc,metaspace ] GC(0) Metaspace: 15062K->15062K(1062912K)
[2022-04-26T22:11:29.437+0900][gc ] GC(0) Pause Young (Normal) (G1 Evacuation Pause) 25M->7M(512M) 6.276ms
[2022-04-26T22:11:29.437+0900][gc,cpu ] GC(0) User=0.03s Sys=0.01s Real=0.00s