เรียนรู้วิธีใช้ node Kafka Trigger ใน n8n ปฏิบัติตามเอกสารทางเทคนิคเพื่อรวม node Kafka Trigger เข้ากับ workflow ของคุณ
คาฟคา เป็นแพลตฟอร์มการสตรีมเหตุการณ์แบบโอเพ่นซอร์สแบบกระจายที่สามารถใช้กับไปป์ไลน์ข้อมูลประสิทธิภาพสูง การวิเคราะห์การสตรีม การรวมข้อมูล และแอปพลิเคชันที่มีภารกิจสำคัญ
Credentials
อ้างถึง Kafka credentials สำหรับข้อมูลการตรวจสอบสิทธิ์สำหรับ node นี้
Schema Registry
หากต้องการถอดรหัสข้อความด้วย Confluent Schema Registry ที่ได้รับการตรวจสอบสิทธิ์ (เช่น Confluent Cloud) ให้เปิดใช้งาน Use Schema Registry ใน node และเพิ่ม Schema Registry credentials.
การบีบอัดข้อความ (Message compression)
Kafka Trigger สามารถใช้ข้อความที่ไม่มีการบีบอัดและข้อความที่บีบอัดด้วย GZIP . มันไม่สามารถถอดรหัสข้อความที่บีบอัดได้ด้วย LZ4 , Snappy หรือ Zstd (ค่าเริ่มต้นทั่วไปสำหรับผู้ผลิต Confluent และ JVM): การใช้หัวข้อดังกล่าวล้มเหลวโดยมีข้อผิดพลาดในรูปแบบการบีบอัดที่ไม่รองรับ หากต้องการใช้หัวข้อ ให้กำหนดค่าผู้ผลิตให้ใช้ gzip หรือไม่บีบอัด
ตัวอย่างและแม่แบบ (Examples and templates)
สำหรับตัวอย่างการใช้งานและเทมเพลตเพื่อช่วยคุณในการเริ่มต้น โปรดดูที่ n8n's การบูรณาการ Kafka Trigger หน้า
ตัวอย่าง Kafka Trigger เวอร์ชัน 2
ความพร้อมใช้งานของคุณสมบัติ (Feature availability)
Kafka Trigger เวอร์ชัน 2 เป็นตัวอย่าง คุณสมบัติการแสดงตัวอย่างอาจมีการเปลี่ยนแปลงในรุ่นต่อๆ ไป ดังนั้นควรหลีกเลี่ยงการพึ่งพาคุณสมบัติเหล่านี้ใน workflow การผลิต
Kafka Trigger เวอร์ชัน 2 ทำงานต่อไป @confluentinc/kafka-javascript ไคลเอ็นต์ที่รองรับของ Confluent ที่สร้างขึ้นบน librdkafka โดยจะแทนที่ kafkajs ซึ่งเป็นไลบรารี่ที่ไม่ได้รับการดูแลซึ่งเวอร์ชัน 1 ใช้ trigger จะเก็บช่องและ credentials เดียวกันกับเวอร์ชัน 1 และเพิ่มลักษณะการทำงาน 2 รายการดังนี้
- มันถอดรหัสข้อความที่บีบอัดด้วยตัวแปลงสัญญาณใด ๆ ( GZIP , LZ4 , Snappy และ Zstd ) ในขณะที่เวอร์ชัน 1 จะจัดการเฉพาะข้อความที่ไม่มีการบีบอัดและข้อความ GZIP
- จะตรวจสอบการเชื่อมต่อเมื่อคุณเผยแพร่ workflow หากหัวข้อหายไปหรือผู้บริโภคไม่สามารถเข้าร่วมกลุ่มได้ การเผยแพร่จะล้มเหลวโดยมีข้อผิดพลาดที่ชัดเจน แทนที่จะ trigger โดยไม่ใช้อะไรเลย
เวอร์ชัน 2 ถูกปิดใช้งานโดยค่าเริ่มต้นระหว่างการแสดงตัวอย่าง trigger ที่เพิ่มจากแผง node จะยังคงเป็นเวอร์ชัน 1.3 และไม่มีเครื่องมือเลือกเวอร์ชันในตัวแก้ไข หากต้องการเลือกใช้ ให้นำเข้า JSON workflow ที่มี node Kafka Trigger "typeVersion": 2 . n8n ได้ตรวจสอบการแสดงตัวอย่างบนอิมเมจ n8n Docker อย่างเป็นทางการ ทั้งบน amd64 และ arm64 เวอร์ชัน 2 มีคอมโพเนนต์ที่คอมไพล์แล้ว ดังนั้นวิธีการติดตั้งอื่นๆ เช่น npm หรืออิมเมจที่กำหนดเอง จะไม่ได้รับการยืนยันในระหว่างการแสดงตัวอย่าง
ไลบรารีไคลเอ็นต์เวอร์ชัน 1 และเวอร์ชัน 2 ไม่สามารถสร้างกลุ่มผู้บริโภคร่วมกันได้ ดังนั้นให้เลือกรหัสกลุ่มผู้บริโภคเพื่อให้ตรงกับเป้าหมายของคุณ:
- เพื่อเรียกใช้เวอร์ชัน 1 และเวอร์ชัน 2 เคียงข้างกัน (To run version 1 and version 2 side by side) ให้เวอร์ชัน 2 trigger ID กลุ่มผู้บริโภคของตัวเอง trigger ทั้งสองจะเป็นอิสระจากกัน และแต่ละ trigger จะได้รับทุกข้อความในหัวข้อ
- หากต้องการย้ายไปยังเวอร์ชัน 2 (To migrate to version 2) ให้คงรหัสกลุ่มผู้บริโภคเดิมไว้แต่เรียกใช้ trigger ครั้งละ 1 รายการเท่านั้น ยกเลิกการเผยแพร่ workflow เวอร์ชัน 1 ก่อน จากนั้นจึงเผยแพร่ workflow เวอร์ชัน 2 จะกลับมาทำงานต่อจากตำแหน่งที่คอมมิต ดังนั้นจึงไม่ประมวลผลซ้ำหรือข้ามสิ่งใดไป
- อย่าเผยแพร่ trigger ทั้งสองในรหัสกลุ่มผู้บริโภคเดียวกัน (Don't publish both triggers on the same consumer group ID.) trigger เวอร์ชัน 2 ไม่สามารถเผยแพร่โดยมีข้อผิดพลาดที่มองเห็นได้ แต่ตั้งค่ารหัสกลุ่มล่วงหน้าแทนที่จะอาศัยข้อผิดพลาดนั้น
ก่อนที่จะเปลี่ยน workflow เป็นเวอร์ชัน 2 ให้ดาวน์โหลดสำเนาของ workflow ดังกล่าวเป็นจุดย้อนกลับ หากต้องการย้อนกลับ ให้ลบ node เวอร์ชัน 2 และเพิ่ม node ใหม่ Kafka Trigger node จากแผงควบคุม (ค่าเริ่มต้นเป็นเวอร์ชัน 1.3) หรือกู้คืนการส่งออกตัวอย่างก่อนของคุณ
