เรียนรู้วิธีใช้ node Kafka ใน n8n ปฏิบัติตามเอกสารทางเทคนิคเพื่อรวม node Kafka เข้ากับ workflow ของคุณ
ใช้ node Kafka เพื่อทำงานใน Kafka โดยอัตโนมัติ และผสานรวม Kafka เข้ากับแอปพลิเคชันอื่นๆ n8n มีการรองรับฟีเจอร์ Kafka ที่หลากหลายในตัว รวมถึงการส่งข้อความด้วย
ในหน้านี้ คุณจะพบรายการการดำเนินการที่ node Kafka รองรับและลิงก์ไปยังแหล่งข้อมูลเพิ่มเติม
Credentials
อ้างถึง Kafka credentials สำหรับคำแนะนำในการตั้งค่าการรับรองความถูกต้อง
Schema Registry
หากต้องการเข้ารหัสข้อความด้วย Confluent Schema Registry ที่ได้รับการตรวจสอบสิทธิ์ (เช่น Confluent Cloud) ให้เปิดใช้งาน Use Schema Registry ใน node และเพิ่ม Schema Registry credentials.
node นี้สามารถใช้เป็นเครื่องมือ AI ได้ (This node can be used as an AI tool)
node นี้สามารถใช้เพื่อเพิ่มขีดความสามารถของ AI Agent เมื่อใช้ในลักษณะนี้ parameter จำนวนมากสามารถตั้งค่าได้โดยอัตโนมัติ หรือด้วยข้อมูลที่ควบคุมโดย AI ดูข้อมูลเพิ่มเติมได้ใน เอกสารประกอบ parameter เครื่องมือ AI .
การดำเนินงาน
- ส่งข้อความ
การแสดงตัวอย่าง node Kafka เวอร์ชัน 2
ความพร้อมใช้งานของคุณสมบัติ (Feature availability)
เวอร์ชัน 2 ของ node Kafka เป็นตัวอย่าง คุณสมบัติการแสดงตัวอย่างอาจมีการเปลี่ยนแปลงในรุ่นต่อๆ ไป ดังนั้นควรหลีกเลี่ยงการพึ่งพาคุณสมบัติเหล่านี้ใน workflow การผลิต
node Kafka เวอร์ชัน 2 ทำงานอยู่ @confluentinc/kafka-javascript ไคลเอ็นต์ที่รองรับของ Confluent ที่สร้างขึ้นบน librdkafka โดยจะแทนที่ kafkajs ซึ่งเป็นไลบรารี่ที่ไม่ได้รับการดูแลซึ่งเวอร์ชัน 1 ใช้ node เก็บฟิลด์และ credentials เดียวกันกับเวอร์ชัน 1 การเปลี่ยนแปลงที่มองเห็นได้เพียงอย่างเดียวคือการเปลี่ยนแปลงใหม่ Compression parameter ซึ่งบีบอัดข้อความที่คุณส่งด้วย GZIP , Snappy, LZ4 หรือ Zstd . หาก Kafka Trigger เวอร์ชัน 1 ใช้หัวข้อ ให้คงไว้ Compression ตั้งค่าเป็น GZIP หรือ None : trigger เวอร์ชัน 1 ไม่สามารถถอดรหัสตัวแปลงสัญญาณอื่นๆ ได้
เวอร์ชัน 2 ถูกปิดใช้งานโดยค่าเริ่มต้นระหว่างการแสดงตัวอย่าง node ที่เพิ่มจากแผง node จะยังคงเป็นเวอร์ชัน 1 และไม่มีเครื่องมือเลือกเวอร์ชันในตัวแก้ไข หากต้องการเลือกใช้ ให้นำเข้า JSON workflow ที่มี node Kafka "typeVersion": 2 . n8n ได้ตรวจสอบการแสดงตัวอย่างบนอิมเมจ n8n Docker อย่างเป็นทางการ ทั้งบน amd64 และ arm64 เวอร์ชัน 2 มีคอมโพเนนต์ที่คอมไพล์แล้ว ดังนั้นวิธีการติดตั้งอื่นๆ เช่น npm หรืออิมเมจที่กำหนดเอง จะไม่ได้รับการยืนยันในระหว่างการแสดงตัวอย่าง
ก่อนที่จะเปลี่ยน workflow เป็นเวอร์ชัน 2 ให้ดาวน์โหลดสำเนาของ workflow ดังกล่าวเป็นจุดย้อนกลับ หากต้องการย้อนกลับ ให้ลบ node เวอร์ชัน 2 และเพิ่ม node ใหม่ Kafka node จากแผงควบคุม (ค่าเริ่มต้นเป็นเวอร์ชัน 1) หรือกู้คืนการส่งออกตัวอย่างก่อนของคุณ
หากต้องการใช้ข้อความเวอร์ชัน 2 รวมถึงคำแนะนำเกี่ยวกับรหัสกลุ่มผู้บริโภค โปรดดูที่ ตัวอย่าง Kafka Trigger เวอร์ชัน 2 .
เทมเพลตและตัวอย่าง
เรียกดูเทมเพลตการรวมเอกสาร node Kafka หรือ ค้นหาเทมเพลตทั้งหมด
