chúng tôi có 3 nhà môi giới Kafka trên Linux RHEL 7.6 (3 máy linux)
phiên bản kafka là 2.7.X
ID của người môi giới là - 1010,1011,1012
từ kafka được mô tả, chúng ta có thể thấy như sau
Chủ đề: __consumer_offsets Phân vùng: 0 Nhà lãnh đạo: không Bản sao: 1011,1010,1012 Isr: 1010
Chủ đề: __consumer_offsets Phân vùng: 1 Lãnh đạo: 1012 Bản sao: 1012,1011,1010 Isr: 1012,1011
Chủ đề: __consumer_offsets Phân vùng: 2 Nhà lãnh đạo: 1011 Bản sao: 1010,1012,1011 Isr: 1011,1012
Chủ đề: __consumer_offsets Phân vùng: 3 Nhà lãnh đạo: không Bản sao: 1011,1012,1010 Isr: 1010
Chủ đề: __consumer_offsets Phân vùng: 4 Nhà lãnh đạo: 1011 Bản sao: 1012,1010,1011 Isr: 1011
Chủ đề: __consumer_offsets Phân vùng: 5 Nhà lãnh đạo: không Bản sao: 1010,1011,1012 Isr: 1010
từ Zookeeper cli chúng ta có thể thấy nhà môi giới đó mã số 1010 không xác định
[zk: localhost:2181(CONNECTED) 10] ls /brokers/ids
[1011, 1012]
và từ nhật ký - thay đổi trạng thái.log
chúng ta có thể thấy như sau
[2021-12-16 14:15:36,170] WARN [Broker id=1010] Bỏ qua yêu cầu LeaderAndIsr từ bộ điều khiển 1010 với id tương quan 485 epoch 323 cho phân vùng __consumer_offsets-6 vì bản sao cục bộ của phân vùng nằm trong thư mục nhật ký ngoại tuyến ( trạng thái.change.logger)
[2021-12-16 14:15:36,170] WARN [Broker id=1010] Bỏ qua yêu cầu LeaderAndIsr từ bộ điều khiển 1010 với id tương quan 485 epoch 323 cho phân vùng __consumer_offsets-9 vì bản sao cục bộ của phân vùng nằm trong một thư mục nhật ký ngoại tuyến ( trạng thái.change.logger)
[2021-12-16 14:15:36,170] WARN [Broker id=1010] Bỏ qua yêu cầu LeaderAndIsr từ bộ điều khiển 1010 với id tương quan 485 epoch 323 cho phân vùng __consumer_offsets-8 vì bản sao cục bộ của phân vùng nằm trong thư mục nhật ký ngoại tuyến ( trạng thái.change.logger)
[2021-12-16 14:15:36,170] WARN [Broker id=1010] Bỏ qua yêu cầu LeaderAndIsr từ bộ điều khiển 1010 với id tương quan 485 epoch 323 cho phân vùng __consumer_offsets-11 vì bản sao cục bộ của phân vùng nằm trong thư mục nhật ký ngoại tuyến ( trạng thái.change.logger)
[2021-12-16 14:15:36,170] WARN [Broker id=1010] Bỏ qua yêu cầu LeaderAndIsr từ bộ điều khiển 1010 với id tương quan 485 epoch 323 cho phân vùng __consumer_offsets-10 làm bản sao cục bộ cho phân vùng nằm trong thư mục nhật ký ngoại tuyến ( trạng thái.change.logger)
[2021-12-16 14:15:36,170] WARN [Broker id=1010] Bỏ qua yêu cầu LeaderAndIsr từ bộ điều khiển 1010 với id tương quan 485 epoch 323 cho phân vùng __consumer_offsets-46 làm bản sao cục bộ cho phân vùng nằm trong thư mục nhật ký ngoại tuyến ( trạng thái.change.logger)
[2021-12-16 14:15:36,170] WARN [Broker id=1010] Bỏ qua yêu cầu LeaderAndIsr từ bộ điều khiển 1010 với id tương quan 485 epoch 323 cho phân vùng __consumer_offsets-45 làm bản sao cục bộ cho phân vùng nằm trong thư mục nhật ký ngoại tuyến ( trạng thái.change.logger)
[2021-12-16 14:15:36,170] WARN [Broker id=1010] Bỏ qua yêu cầu LeaderAndIsr từ bộ điều khiển 1010 với id tương quan 485 epoch 323 cho phân vùng __consumer_offsets-48 làm bản sao cục bộ cho phân vùng nằm trong thư mục nhật ký ngoại tuyến ( trạng thái.change.logger)
[2021-12-16 14:15:36,170] WARN [Broker id=1010] Bỏ qua yêu cầu LeaderAndIsr từ bộ điều khiển 1010 với id tương quan 485 epoch 323 cho phân vùng __consumer_offsets-47 làm bản sao cục bộ cho phân vùng nằm trong thư mục nhật ký ngoại tuyến ( trạng thái.change.logger)
[2021-12-16 14:15:36,170] WARN [Broker id=1010] Bỏ qua yêu cầu LeaderAndIsr từ bộ điều khiển 1010 với id tương quan 485 epoch 323 cho phân vùng __consumer_offsets-49 vì bản sao cục bộ của phân vùng nằm trong thư mục nhật ký ngoại tuyến ( trạng thái.change.logger)
bởi ls -ltr , chúng ta có thể thấy rằng bộ điều khiển.log và thay đổi trạng thái.log không được cập nhật từ 16 tháng 12
-rwxr-xr-x 1 gốc kafka 343477146 Ngày 16 tháng 12 14:15 controller.log
-rwxr-xr-x 1 gốc kafka 207911766 Ngày 16 tháng 12 14:15 trạng thái-change.log
-rw-r--r-- 1 root kafka 68759461 Ngày 16 tháng 12 14:15 kafkaServer-gc.log.6.current
-rwxr-xr-x 1 root kafka 6570543 Ngày 17 tháng 12 09:42 log-cleaner.log
-rw-r--r-- 1 root kafka 524288242 Ngày 20 tháng 12 00:39 server.log.10
-rw-r--r-- 1 root kafka 524289332 Ngày 20 tháng 12 01:37 server.log.9
-rw-r--r-- 1 gốc kafka 524288452 Ngày 20 tháng 12 02:35 server.log.8
-rw-r--r-- 1 root kafka 524288625 Ngày 20 tháng 12 03:33 server.log.7
-rw-r--r-- 1 root kafka 524288395 Ngày 20 tháng 12 04:30 server.log.6
-rw-r--r-- 1 root kafka 524288237 Ngày 20 tháng 12 05:27 server.log.5
-rw-r--r-- 1 gốc kafka 524289136 Ngày 20 tháng 12 06:25 server.log.4
-rw-r--r-- 1 gốc kafka 524288142 Ngày 20 tháng 12 07:25 server.log.3
-rw-r--r-- 1 root kafka 524288187 Ngày 20 tháng 12 08:21 server.log.2
-rw-r--r-- 1 root kafka 524288094 Ngày 20 tháng 12 10:52 server.log.1
-rw-r--r-- 1 gốc kafka 323361 Ngày 20 tháng 12 19:50 kafkaServer-gc.log.0.current
-rw-r--r-- 1 gốc kafka 323132219 ngày 20 tháng 12 19:50 server.log
-rwxr-xr-x 1 root kafka 15669106 Ngày 20 tháng 12 19:50 kafkaServer.out
những gì chúng tôi đã làm cho đến bây giờ là:
chúng tôi khởi động lại cả 3 máy chủ vườn thú
chúng tôi khởi động lại tất cả các nhà môi giới kafka
nhưng vẫn là nhà môi giới kafka 1010 Xuất hiện dưới dạng lãnh đạo không có và không có trong dữ liệu của người quản lý vườn thú
thông tin bổ sung
[zk: localhost:2181(CONNECTED) 11] lấy /bộ điều khiển
{"version":1,"brokerid":1011,"timestamp":"1640003679634"}
cZxid = 0x4900000b0c
ctime = Thứ Hai ngày 20 tháng 12 12:34:39 UTC 2021
mZxid = 0x4900000b0c
mtime = Thứ Hai ngày 20 tháng 12 12:34:39 UTC 2021
pZxid = 0x4900000b0c
chuyển đổi = 0
phiên bản dữ liệu = 0
phiên bản acl = 0
ephemeralOwner = 0x27dd7cf43350080
chiều dài dữ liệu = 57
numTrẻ em = 0
từ kafka01
thêm meta.properties
#
#Thứ Ba 16 tháng 11 07:45:36 UTC 2021
cluster.id=D3KpekCETmaNveBJzE6PZg
phiên bản = 0
nhà môi giới.id=1010
ý tưởng có liên quan
trong đĩa chủ đề, chúng tôi có các tệp sau (bổ sung cho các phân vùng chủ đề)
-rw-r--r-- 1 root kafka 91 ngày 16 tháng 11 07:45 meta.properties
-rw-r--r-- 1 gốc kafka 161 ngày 15 tháng 12 16:04 điểm kiểm tra bù đắp sạch hơn
-rw-r--r-- 1 root kafka 13010 15 tháng 12 16:20 điểm kiểm tra sao chép-bù đắp
-rw-r--r-- 1 gốc kafka 1928 ngày 17 tháng 12 09:42 recovery-point-offset-checkpoint
-rw-r--r-- 1 root kafka 80 ngày 17 tháng 12 09:42 log-start-offset-checkpoint
bất kỳ ý tưởng nào nếu việc xóa một hoặc nhiều tệp ở trên có thể giúp giải quyết vấn đề của chúng tôi?
