AWS Lambda ประกาศการสนับสนุนดั้งเดิมสำหรับกิจกรรม Kafka ที่ฟอร์แมต Avro และ Protobuf
ขณะนี้ AWS Lambda ให้การสนับสนุนดั้งเดิมสำหรับเหตุการณ์ Kafka ที่ฟอร์แมต Avro และ Protobuf ด้วยการแมปแหล่งเหตุการณ์ (ESM) ของ Apache Kafka และผสานรวมเข้ากับรีจิสทรีสคีมา AWS Glue (GSR), รีจิสทรีสคีมา Confluent Cloud (CCSR) และรีจิสทรีสคีมา Confluent (SCSR) ที่จัดการด้วยตนเองสำหรับการจัดการสคีมา ลักษณะนี้ช่วยให้คุณสามารถตรวจสอบสคีมา กรองกิจกรรม และประมวลผลเหตุการณ์ของคุณโดยใช้อินเทอร์เฟซผู้บริโภค Kafka แบบโอเพนซอร์ส นอกจากนี้ ลูกค้าสามารถใช้ Powertools for AWS Lambda เพื่อประมวลผลกิจกรรม Kafka ของตนโดยไม่ต้องเขียนโค้ดการดีซีเรียลไลเซชันแบบกำหนดเอง ทำให้สร้างแอปพลิเคชัน Kafka ด้วย AWS Lambda ได้ง่ายขึ้น
ลูกค้า Kafka ใช้ฟอร์แมต Avro และ Protobuf สำหรับพื้นที่เก็บข้อมูลที่มีประสิทธิภาพ การซีเรียลไลเซชันและการดีซีเรียลไลเซชันที่รวดเร็ว การสนับสนุนวิวัฒนาการของสคีมา และการทำงานร่วมกันระหว่างภาษาโปรแกรมที่แตกต่างกัน ลูกค้าใช้รีจิสทรีสคีมาเพื่อจัดการ พัฒนา และตรวจสอบสคีมาก่อนที่ข้อมูลจะเข้าสู่ไปป์ไลน์การประมวลผล ก่อนหน้านี้ ลูกค้าจำเป็นต้องเขียนโค้ดที่กำหนดเองภายในฟังก์ชัน Lambda เพื่อตรวจสอบ ดีซีเรียลไลซ์ และกรองกิจกรรมเมื่อใช้รูปแบบข้อมูลเหล่านี้ Lambda ซึ่งเปิดตัวในวันนี้ รองรับ Avro และ Protobuf แบบดั้งเดิมรวมถึงการบูรณาการกับ GSR, CCSR และ SCSR ทำให้ลูกค้าสามารถประมวลผลกิจกรรม Kafka โดยใช้รูปแบบข้อมูลเหล่านี้โดยไม่ต้องเขียนโค้ดที่กำหนดเอง นอกจากนี้ ลูกค้าสามารถเพิ่มประสิทธิภาพค่าใช้จ่ายผ่านการกรองกิจกรรมเพื่อป้องกันการเรียกดำเนินการฟังก์ชันที่ไม่จำเป็น
โดยทั่วไปแล้ว ฟีเจอร์นี้มีให้บริการในทุกภูมิภาค AWS เชิงพาณิชย์ที่มีบริการ AWS Lambda Kafka ESM ยกเว้นอิสราเอล (เทลอาวีฟ), เอเชียแปซิฟิก (มาเลเซีย) และแคนาดาตะวันตก (คาลการี)
หากต้องการเริ่มต้นใช้งาน ให้กำหนดค่ารีจิสทรีสคีมาของคุณสำหรับ Kafka ESM ใหม่หรือที่มีอยู่ใน ESM API, คอนโซล AWS, AWS CLI, AWS SDK, AWS CloudFormation และ AWS SAM หรือคุณอาจเลือกตั้งค่ากฎการกรองเพื่อละทิ้งกิจกรรมที่ฟอร์แมต Avro หรือ Protobuf ที่ไม่เกี่ยวข้องก่อนการเรียกดำเนินการฟังก์ชัน หากต้องการสร้างฟังก์ชันของคุณด้วยอินเทอร์เฟซ ConsumerRecords แบบโอเพนซอร์สของ Kafka ให้เพิ่ม Powertools สำหรับ AWS Lambda เพื่อเป็นการขึ้นต่อกันภายในฟังก์ชัน Lambda ของคุณ หากต้องการเรียนรู้เพิ่มเติม อ่านเอกสารประกอบ Lambda ESM และการกำหนดราคา AWS Lambda