แชร์ผ่าน

เพิ่มแหล่ง Kafka ของ Confluent ไปยังกระแสเหตุการณ์

  • บทความ

บทความนี้แสดงวิธีการเพิ่มแหล่งข้อมูล Confluent Kafka ไปยังเหตุการณ์

Confluent Cloud Kafka เป็นแพลตฟอร์มการสตรีมที่นําเสนอฟังก์ชันการสตรีมข้อมูลและการประมวลผลที่มีประสิทธิภาพโดยใช้ Apache Kafka โดยการรวม Confluent Cloud Kafka เป็นแหล่งข้อมูลภายในเหตุการณ์ของคุณ คุณสามารถประมวลผลสตรีมข้อมูลแบบเรียลไทม์ได้อย่างราบรื่นก่อนที่จะกําหนดเส้นทางไปยังหลายปลายทางภายใน Fabric

หมายเหตุ

แหล่งข้อมูลนี้ไม่ได้รับการสนับสนุนในภูมิภาคต่อไปนี้ของความจุพื้นที่ทํางานของคุณ: US3 ตะวันตก สวิตเซอร์แลนด์ตะวันตก

ข้อกำหนดเบื้องต้น

  • เข้าถึงพื้นที่ทํางานในโหมดสิทธิ์การใช้งาน Fabric capacity (หรือ) โหมดสิทธิ์การใช้งานรุ่นทดลองใช้ที่มีสิทธิ์ผู้สนับสนุนหรือสูงกว่า
  • คลัสเตอร์ Confluent Cloud Kafka และคีย์ API
  • คลัสเตอร์ Confluent Cloud Kafka ของคุณจะต้องสามารถเข้าถึงได้โดยสาธารณะ และไม่ได้อยู่หลังไฟร์วอลล์หรือการรักษาความปลอดภัยในเครือข่ายเสมือน
  • ถ้าคุณไม่มีเหตุการณ์สตรีม ให้สร้างเหตุการณ์สตรีม

เปิดใช้ตัวช่วยสร้างการเลือกแหล่งข้อมูล

ถ้าคุณยังไม่ได้เพิ่มแหล่งข้อมูลใด ๆ ลงในเหตุการณ์สตรีมของคุณ ให้เลือก ใช้ไทล์แหล่งข้อมูล ภายนอก

สกรีนช็อตที่แสดงการเลือกใช้ไทล์แหล่งข้อมูลภายนอก

ถ้าคุณกําลังเพิ่มแหล่งข้อมูลไปยังเหตุการณ์สตรีมที่เผยแพร่แล้ว สลับไปยัง โหมดแก้ไข เลือก เพิ่มแหล่งข้อมูล บนริบบอน แล้วเลือก แหล่งข้อมูลภายนอก

สกรีนช็อตที่แสดงการเลือกเพิ่มแหล่งข้อมูลไปยังเมนูแหล่งข้อมูลภายนอก  

กําหนดค่าและเชื่อมต่อกับ Confluent Kafka

  1. บนหน้า เลือกแหล่งข้อมูล ให้เลือก สับสน

    สกรีนช็อตที่แสดงการเลือกของ Confluent เป็นชนิดแหล่งข้อมูลในตัวช่วยสร้างรับเหตุการณ์

  2. เมื่อต้องการสร้างการเชื่อมต่อไปยังแหล่งข้อมูล Confluent Cloud Kafka ให้เลือก การเชื่อมต่อใหม่

    สกรีนช็อตที่แสดงการเลือกลิงก์การเชื่อมต่อใหม่บนหน้าเชื่อมต่อของตัวช่วยสร้างรับเหตุการณ์

  3. ในส่วนการตั้งค่าการเชื่อมต่อ ให้ใส่เซิร์ฟเวอร์ Confluent Bootstrap นําทางไปยังโฮมเพจ Confluent Cloud ของคุณ เลือก การตั้งค่าคลัสเตอร์และคัดลอกที่อยู่ไปยังเซิร์ฟเวอร์ Bootstrap ของคุณ

  4. ในส่วนข้อมูลประจําตัวการเชื่อมต่อ ถ้าคุณมีการเชื่อมต่อที่มีอยู่ไปยังคลัสเตอร์ Confluent เลือกจากรายการดรอปดาวน์สําหรับการเชื่อมต่อ มิฉะนั้น ให้ทําตามขั้นตอนเหล่านี้:

    1. สําหรับ ชื่อการเชื่อมต่อ ให้ใส่ชื่อสําหรับการเชื่อมต่อ
    2. สําหรับ ชนิดการรับรองความถูกต้อง ให้ยืนยันว่ามี การเลือกคีย์ Cloud ของ Confluent
    3. สําหรับ คีย์ API และข้อมูล ลับของคีย์ API:

      1. นําทางไปยัง Confluent Cloud ของคุณ

      2. เลือก คีย์ API บนเมนูด้านข้าง

      3. เลือก ปุ่มเพิ่มคีย์ เพื่อสร้างคีย์ API ใหม่

      4. คัดลอกคีย์ API และข้อมูลลับ

      5. วางค่าเหล่านั้นลงในเขตข้อมูลคีย์ API และ API Key Secret

      6. เลือก เชื่อมต่อ

        สกรีนช็อตที่แสดงหน้าแรกของการตั้งค่าการเชื่อมต่อแบบสับสน

  5. เลื่อนเพื่อดูส่วน กําหนดค่าแหล่งข้อมูล Confluent บนหน้า ใส่ข้อมูลเพื่อทําให้การกําหนดค่าแหล่งข้อมูล Confluent เสร็จสมบูรณ์

    1. สําหรับ หัวข้อ ให้ใส่ชื่อหัวข้อจากคลาวด์ที่สับสนของคุณ คุณสามารถสร้างหรือจัดการหัวข้อของคุณใน Confluent Cloud Console
    2. สําหรับ กลุ่มผู้บริโภค ให้ใส่กลุ่มผู้บริโภคของ Confluent Cloud ของคุณ ซึ่งจะมอบกลุ่มผู้บริโภคเฉพาะสําหรับการรับเหตุการณ์จากคลัสเตอร์ Confluent Cloud ให้กับคุณ
    3. สําหรับ รีเซ็ตการตั้งค่าออฟเซต อัตโนมัติ ให้เลือกค่าใดค่าหนึ่งต่อไปนี้:

      • แรกเริ่ม – ข้อมูลแรกเริ่มที่พร้อมใช้งานจากคลัสเตอร์ Confluent ของคุณ

      • ล่าสุด – ข้อมูลที่พร้อมใช้งานล่าสุด

      • None – อย่าตั้งค่าออฟเซตโดยอัตโนมัติ

        สกรีนช็อตที่แสดงหน้าที่สอง - กําหนดค่าหน้าแหล่งข้อมูลที่สับสน - ของการตั้งค่าการเชื่อมต่อที่สับสน

  6. เลือก ถัดไป บนหน้าจอ ตรวจสอบและสร้าง ให้ตรวจสอบสรุป จากนั้นเลือก เพิ่ม

คุณจะเห็นว่าแหล่งข้อมูล Confluent Cloud Kafka ถูกเพิ่มไปยังกระแสข้อมูลของคุณบนพื้นที่ทํางานในโหมดแก้ไข หากต้องการใช้แหล่งข้อมูล Confluent Cloud Kafka ที่เพิ่งเพิ่มเข้าไปใหม่ ให้เลือก เผยแพร่ บนริบบอน

สกรีนช็อตที่แสดงแหล่งข้อมูล Confluent Kafka ในมุมมองแก้ไข

หลังจากที่คุณทําตามขั้นตอนเหล่านี้แหล่งข้อมูล Confluent Cloud Kafka จะพร้อมใช้งานสําหรับการแสดงภาพใน Live view

สกรีนช็อตที่แสดงแหล่งข้อมูล Confluent Kafka ในมุมมองสด

ข้อจำกัด

  • Confluent Kafka ที่มีรูปแบบ JSON และ Avro โดยใช้รีจิสทรี schema ไม่ได้รับการสนับสนุนในขณะนี้
  • การถอดรหัสข้อมูลจาก Confluent Kafka โดยใช้การลงทะเบียน Schema ของ Confluent ยังไม่ได้รับการรองรับในขณะนี้

หมายเหตุ

จํานวนสูงสุดของแหล่งข้อมูลและปลายทางสําหรับหนึ่งเหตุการณ์สตรีมคือ 11

เนื้อหาที่เกี่ยวข้อง

ตัวเชื่อมต่ออื่นๆ: