คาฟคา + ไม่มีผู้นำ + และรหัสนายหน้าคาฟคาไม่ได้ลงชื่อเข้าใช้ผู้ดูแลสวนสัตว์

เรามี 3 โบรกเกอร์ Kafka บน Linux RHEL 7.6 ( 3 เครื่อง linux )

รุ่นคาฟคาคือ 2.7.X

รหัสโบรกเกอร์คือ - 1010,1011,1012

จากคาฟคาที่อธิบายเราสามารถเห็นสิ่งต่อไปนี้

 หัวข้อ: __consumer_offsets Partition: 0 Leader: none Replicas: 1011,1010,1012 Isr: 1010
        หัวข้อ: __consumer_offsets พาร์ติชัน: 1 ผู้นำ: 1012 สำเนา: 1012,1011,1010 Isr: 1012,1011
        หัวข้อ: __consumer_offsets พาร์ติชัน: 2 ผู้นำ: 1011 สำเนา: 1010,1012,1011 Isr: 1011,1012
        หัวข้อ: __consumer_offsets Partition: 3 Leader: none Replicas: 1011,1012,1010 Isr: 1010
        หัวข้อ: __consumer_offsets พาร์ติชัน: 4 ผู้นำ: 1011 แบบจำลอง: 1012,1010,1011 Isr: 1011
        หัวข้อ: __consumer_offsets Partition: 5 Leader: none Replicas: 1010,1011,1012 Isr: 1010

จาก Zookeeper cli เราสามารถเห็นนายหน้าคนนั้น รหัส 1010 ไม่ได้กำหนดไว้

[zk: localhost:2181(เชื่อมต่อ) 10] ls /brokers/ids
[1011, 1012]

และจากบันทึก - state-change.log

เราสามารถเห็นสิ่งต่อไปนี้

[2021-12-16 2021 14:15:36,170] WARN [Broker id=1010] เพิกเฉยต่อคำขอ LeaderAndIsr จากคอนโทรลเลอร์ 1010 ที่มีรหัสความสัมพันธ์ 485 ยุค 323 สำหรับพาร์ติชัน __consumer_offsets-6 เนื่องจากโลคัลเรพลิกาสำหรับพาร์ติชันอยู่ในไดเร็กทอรีบันทึกออฟไลน์ ( state.change.logger)
[2021-12-16 2021 14:15:36,170] WARN [Broker id=1010] เพิกเฉยต่อคำขอ LeaderAndIsr จากคอนโทรลเลอร์ 1010 ที่มี ID ความสัมพันธ์ 485 epoch 323 สำหรับพาร์ติชัน __consumer_offsets-9 เนื่องจากโลคัลเรพลิกาสำหรับพาร์ติชันอยู่ในไดเร็กทอรีบันทึกออฟไลน์ ( state.change.logger)
[2021-12-16 14:15:36,170] WARN [Broker id=1010] เพิกเฉยต่อคำขอ LeaderAndIsr จากคอนโทรลเลอร์ 1010 ที่มี ID ความสัมพันธ์ 485 ยุค 323 สำหรับพาร์ติชัน __consumer_offsets-8 เนื่องจากโลคัลเรพลิกาสำหรับพาร์ติชันอยู่ในไดเร็กทอรีบันทึกออฟไลน์ ( state.change.logger)
[2021-12-16 2021 14:15:36,170] WARN [Broker id=1010] เพิกเฉยต่อคำขอ LeaderAndIsr จากคอนโทรลเลอร์ 1010 ที่มีรหัสความสัมพันธ์ 485 epoch 323 สำหรับพาร์ติชัน __consumer_offsets-11 เนื่องจากโลคัลเรพลิกาสำหรับพาร์ติชันอยู่ในไดเร็กทอรีบันทึกออฟไลน์ ( state.change.logger)
[2021-12-16 14:15:36,170] WARN [Broker id=1010] เพิกเฉยต่อคำขอ LeaderAndIsr จากคอนโทรลเลอร์ 1010 ที่มี ID ความสัมพันธ์ 485 ยุค 323 สำหรับพาร์ติชัน __consumer_offsets-10 เนื่องจากโลคัลเรพลิกาสำหรับพาร์ติชันอยู่ในไดเร็กทอรีบันทึกออฟไลน์ ( state.change.logger)
[2021-12-16 2021 14:15:36,170] WARN [Broker id=1010] เพิกเฉยต่อคำขอ LeaderAndIsr จากคอนโทรลเลอร์ 1010 ที่มีรหัสความสัมพันธ์ 485 ยุค 323 สำหรับพาร์ติชัน __consumer_offsets-46 เนื่องจากโลคัลเรพลิกาสำหรับพาร์ติชันอยู่ในไดเร็กทอรีบันทึกออฟไลน์ ( state.change.logger)
[2021-12-16 2021 14:15:36,170] WARN [Broker id=1010] เพิกเฉยต่อคำขอ LeaderAndIsr จากคอนโทรลเลอร์ 1010 ที่มีรหัสความสัมพันธ์ 485 ยุค 323 สำหรับพาร์ติชัน __consumer_offsets-45 เนื่องจากโลคัลเรพลิกาสำหรับพาร์ติชันอยู่ในไดเร็กทอรีบันทึกออฟไลน์ ( state.change.logger)
[2021-12-16 2021 14:15:36,170] WARN [Broker id=1010] เพิกเฉยต่อคำขอ LeaderAndIsr จากคอนโทรลเลอร์ 1010 ที่มี ID ความสัมพันธ์ 485 ยุค 323 สำหรับพาร์ติชัน __consumer_offsets-48 เนื่องจากโลคัลเรพลิกาสำหรับพาร์ติชันอยู่ในไดเร็กทอรีบันทึกออฟไลน์ ( state.change.logger)
[2021-12-16 14:15:36,170] WARN [Broker id=1010] เพิกเฉยต่อคำขอ LeaderAndIsr จากคอนโทรลเลอร์ 1010 ที่มีรหัสความสัมพันธ์ 485 ยุค 323 สำหรับพาร์ติชัน __consumer_offsets-47 เนื่องจากโลคัลเรพลิกาสำหรับพาร์ติชันอยู่ในไดเร็กทอรีบันทึกออฟไลน์ ( state.change.logger)
[2021-12-16 2021 14:15:36,170] WARN [Broker id=1010] เพิกเฉยต่อคำขอ LeaderAndIsr จากคอนโทรลเลอร์ 1010 ที่มีรหัสความสัมพันธ์ 485 ยุค 323 สำหรับพาร์ติชัน __consumer_offsets-49 เนื่องจากโลคัลเรพลิกาสำหรับพาร์ติชันอยู่ในไดเร็กทอรีบันทึกออฟไลน์ ( state.change.logger)

โดย ls -ltr เราจะเห็นว่า คอนโทรลเลอร์.ล็อก และ state-change.log ไม่ได้อัพเดทจาก 16 ธ.ค

-rwxr-xr-x 1 root kafka 343477146 16 ธันวาคม 14:15 controller.log
-rwxr-xr-x 1 root kafka 207911766 16 ธันวาคม 14:15 state-change.log
-rw-r--r-- 1 รูทคาฟคา 68759461 16 ธ.ค. 14:15 น. kafkaServer-gc.log.6.current
-rwxr-xr-x 1 root kafka 6570543 17 ธ.ค. 09:42 น. log-cleaner.log
-rw-r--r-- 1 รูทคาฟคา 524288242 20 ธันวาคม 00:39 server.log.10
-rw-r--r-- 1 รูทคาฟคา 524289332 20 ธ.ค. 01:37 น. server.log.9
-rw-r--r-- 1 รูทคาฟคา 524288452 20 ธันวาคม 02:35 server.log.8
-rw-r--r-- 1 รูทคาฟคา 524288625 20 ธันวาคม 03:33 server.log.7
-rw-r--r-- 1 รูทคาฟคา 524288395 20 ธ.ค. 04:30 น. server.log.6
-rw-r--r-- 1 รูทคาฟคา 524288237 20 ธันวาคม 05:27 server.log.5
-rw-r--r-- 1 รูทคาฟคา 524289136 20 ธันวาคม 06:25 server.log.4
-rw-r--r-- 1 รูทคาฟคา 524288142 20 ธันวาคม 07:25 server.log.3
-rw-r--r-- 1 รูทคาฟคา 524288187 20 ธันวาคม 08:21 server.log.2
-rw-r--r-- 1 รูทคาฟคา 524288094 20 ธันวาคม 10:52 server.log.1
-rw-r--r-- 1 รูทคาฟคา 323361 20 ธ.ค. 19:50 น. kafkaServer-gc.log.0.current
-rw-r--r-- 1 รูทคาฟคา 323132219 20 ธันวาคม 19:50 server.log
-rwxr-xr-x 1 รูทคาฟคา 15669106 20 ธ.ค. 19:50 น. kafkaServer.out

สิ่งที่เราทำจนถึงตอนนี้คือ:

เรารีสตาร์ทเซิร์ฟเวอร์ผู้ดูแลสัตว์ทั้ง 3 ตัว เรารีสตาร์ทโบรกเกอร์คาฟคาทั้งหมด

แต่ก็ยังเป็นนายหน้าค้าคาฟคา 1010 ปรากฏเป็น ผู้นำไม่มี และไม่อยู่ในข้อมูลผู้ดูแลสัตว์

ข้อมูลเพิ่มเติม

[zk: localhost:2181(เชื่อมต่อ) 11] รับ /controller
{"version":1,"brokerid":1011,"timestamp":"1640003679634"}
cZxid = 0x4900000b0c
ctime = วันจันทร์ที่ 20 ธันวาคม 12:34:39 UTC 2021
mZxid = 0x4900000b0c
mtime = วันจันทร์ที่ 20 ธันวาคม 12:34:39 UTC 2021
pZxid = 0x4900000b0c
เวอร์ชัน = 0
รุ่นข้อมูล = 0
aclVersion = 0
เจ้าของชั่วคราว = 0x27dd7cf43350080
ความยาวข้อมูล = 57
จำนวนเด็ก = 0

จาก kafka01

meta.properties เพิ่มเติม
#
#อ. 16 พ.ย. 07:45:36 UTC 2021
cluster.id=D3KpekCETmaNveBJzE6PZg
รุ่น = 0
นายหน้า.id=1010

ความคิดที่เกี่ยวข้อง

ในดิสก์หัวข้อเรามีไฟล์ต่อไปนี้ (นอกเหนือจากพาร์ติชันหัวข้อ)

-rw-r--r-- 1 รูทคาฟคา 91 พ.ย. 59 07:45 น. meta.properties
-rw-r--r-- 1 รูทคาฟคา 161 ธ.ค. 58 16:04 น. Cleaner-offset-checkpoint
-rw-r--r-- 1 รูทคาฟคา 13010 15 ธ.ค. 16:20 น. การจำลองแบบชดเชยจุดตรวจสอบ
-rw-r--r-- 1 root kafka 1928 17 ธ.ค. 09:42 น. การกู้คืนจุดชดเชยจุดตรวจ
-rw-r--r-- 1 รูทคาฟคา 80 ธันวาคม 17 09:42 น. log-start-offset-checkpoint

ความคิดใด ๆ ว่าการลบไฟล์ด้านบนอย่างน้อยหนึ่งไฟล์สามารถช่วยแก้ปัญหาของเราได้หรือไม่?