Tác giả: Stephan Schiller
Ngày phát hành: 09 APR 2026
Chuyên mục: Amazon Managed Streaming for Apache Kafka (Amazon MSK), Announcements, Intermediate (200), Kiro
Các nhà phát triển làm việc với Amazon Managed Streaming for Apache Kafka (Amazon MSK) thường xuyên phải đưa ra các quyết định đòi hỏi kiến thức vận hành sâu rộng—chọn loại instance phù hợp, chẩn đoán độ trễ của consumer, hoặc lập kế hoạch cho một đợt tăng đột biến lưu lượng truy cập. Trả lời những câu hỏi này có nghĩa là phải tổng hợp tài liệu, số liệu và bí quyết vận hành.
Điều gì sẽ xảy ra nếu IDE của bạn có thể hướng dẫn bạn qua quy trình làm việc đó với chuyên môn và công cụ tích hợp sẵn? Kiro là một IDE tác nhân được hỗ trợ bởi AI cho phép bạn mô tả những gì bạn cần bằng ngôn ngữ tự nhiên. Dù là cấu hình cơ sở hạ tầng hay khắc phục sự cố vận hành, Kiro đều hướng dẫn bạn đến giải pháp.
Trong bài viết này, chúng tôi sẽ chỉ cho bạn cách sử dụng Kiro powers, một khả năng mới trang bị cho Kiro kiến thức theo ngữ cảnh và công cụ. Bạn có thể đơn giản hóa việc quản lý cluster MSK của mình, từ thiết lập ban đầu đến chẩn đoán các vấn đề phổ biến, tất cả thông qua các cuộc trò chuyện bằng ngôn ngữ tự nhiên.
Thách thức khi vận hành cluster MSK Express broker của bạn
Amazon MSK Express Brokers là một dịch vụ được quản lý hoàn toàn, trong đó AWS xử lý phần lớn cơ sở hạ tầng cơ bản. Tuy nhiên, các nhóm nền tảng vẫn cần định cỡ cluster chính xác dựa trên yêu cầu thông lượng. Họ cũng cần hiểu các số liệu Amazon CloudWatch phù hợp trong các vấn đề về hiệu suất và điều tra khi mức sử dụng CPU hoặc độ trễ sao chép cao hơn dự kiến. Tài liệu về các phương pháp hay nhất của MSK trải rộng trên nhiều hướng dẫn của AWS. Điều này làm tốn thời gian để tìm thông tin liên quan trong các sự cố sản xuất. Các thành viên mới trong nhóm phải đối mặt với đường cong học tập trong các hoạt động của MSK và có thể lặp lại các lỗi định cỡ và cấu hình phổ biến.
Mặc dù Express Brokers đơn giản hóa việc quản lý cơ sở hạ tầng, bạn vẫn phải đối mặt với những thách thức vận hành đòi hỏi chuyên môn sâu về Kafka trong ba lĩnh vực:
- Tạo và định cỡ cluster: Bạn vẫn phải chọn loại instance phù hợp, cấu hình mạng và chọn phương thức xác thực. Những quyết định này ảnh hưởng đến chi phí và hiệu suất ngay từ ngày đầu tiên.
- Khả năng quan sát và khắc phục sự cố: Các hoạt động hiệu quả đòi hỏi phải tương quan các số liệu của broker, partition và client. Khắc phục sự cố độ trễ hoặc sao chép vẫn yêu cầu hiểu biết vững chắc về kiến trúc của Express Brokers.
- Quản lý dung lượng: Bạn phải giám sát mức sử dụng CPU, hiểu giới hạn thông lượng trên mỗi broker và mở rộng quy mô trước khi đạt đến ngưỡng điều tiết.
Những thách thức này có nghĩa là việc thiết lập một cluster MSK, phân tích các client chạy chậm hoặc điều tra tải CPU cao đòi hỏi phải tổng hợp tài liệu, chi tiết cấu hình, công cụ CLI và bí quyết vận hành, thường nằm rải rác ở nhiều nguồn. Kiro powers giải quyết những thách thức này bằng cách đưa các phương pháp hay nhất, quy trình làm việc có hướng dẫn và công cụ trực tiếp vào IDE của bạn, giảm rào cản chuyên môn và thời gian chuyển đổi ngữ cảnh giữa tài liệu, console và CLI.
Kiro powers
Kiro powers là một tính năng kết hợp các phương pháp hay nhất, ngữ cảnh chuyên biệt và tích hợp công cụ thành một khả năng duy nhất. Bạn có thể cài đặt powers chỉ với một cú nhấp chuột trong Kiro IDE hoặc thêm chúng từ một URL GitHub công khai. Mỗi Power kết hợp các thành phần sau:
- Các máy chủ Model Context Protocol (MCP) cung cấp cho tác nhân Kiro của bạn quyền truy cập trực tiếp vào cơ sở hạ tầng của bạn. Ví dụ, máy chủ AWS MSK MCP cung cấp các công cụ để tạo cluster, giám sát tình trạng và tối ưu hóa cấu hình.
- Các tệp điều khiển (steering files) cung cấp kiến thức bền vững và hướng dẫn quy trình làm việc mà Kiro tải dựa trên tác vụ của người dùng, chẳng hạn như các phương pháp hay nhất về giám sát hoặc quy trình khắc phục sự cố.
- Các hook tùy chọn chạy các hành động tự động khi các sự kiện IDE xảy ra, chẳng hạn như xác thực cấu hình trước khi triển khai.
Ưu điểm chính của Kiro powers là chúng tải ngữ cảnh động dựa trên tác vụ của người dùng. Thay vì cấu hình mọi máy chủ MCP ngay từ đầu và cung cấp lại ngữ cảnh trong mỗi cuộc trò chuyện, powers kích hoạt các công cụ và kiến thức phù hợp theo yêu cầu. Điều này giữ cho ngữ cảnh của tác nhân của bạn tập trung và phù hợp. Trong phần tiếp theo, chúng ta sẽ xem xét cách các thành phần này hoạt động cùng nhau đặc biệt cho các hoạt động của MSK Express Broker.
MSK Express broker power
MSK Express broker power đóng gói máy chủ AWS MSK MCP với hướng dẫn vận hành streaming có mục tiêu, cung cấp cho tác nhân Kiro của bạn chuyên môn về các hoạt động và quản lý cluster của MSK Express Broker. Bạn có thể sử dụng nó để xây dựng các ứng dụng streaming dựa trên Kafka thông qua Kiro trong khi vẫn duy trì các phương pháp hay nhất của Express broker trong suốt vòng đời phát triển.
Đối với các hoạt động của cluster, bạn có thể tạo các cluster Express broker, giám sát các số liệu sức khỏe và quản lý cấu hình thông qua ngôn ngữ tự nhiên. Bạn có thể truy xuất siêu dữ liệu cluster, kiểm tra các endpoint của broker và xác minh trạng thái sao chép. Power cũng hỗ trợ giám sát hoạt động. Bạn có thể theo dõi mức sử dụng CPU, giới hạn thông lượng, phân phối partition và các số liệu kết nối AWS Identity and Access Management (IAM).
Để xem cách hoạt động này trong thực tế, đây là những gì xảy ra khi bạn tương tác với Power: Khi bạn yêu cầu Kiro tạo một cluster MSK, Power sẽ đề xuất kích thước instance phù hợp dựa trên yêu cầu thông lượng của bạn. Khi bạn đang khắc phục sự cố, nó biết cách kiểm tra LeaderCount trước khi đi sâu vào các số liệu mạng. Khi bạn đang khắc phục sự cố xác thực, nó sẽ đề xuất các cài đặt client như reconnect.backoff.ms và group.instance.id để giải quyết các vấn đề về churn kết nối và cân bằng lại so với giới hạn của Express broker. Các trường hợp sử dụng bao gồm:
- Định cỡ và tạo cluster: Mô tả yêu cầu thông lượng của bạn (ví dụ: “50 MBps ingress với 3x fan-out”) và Power sẽ tính toán loại instance và số lượng broker phù hợp, sau đó hướng dẫn bạn tạo cluster.
- Giám sát sức khỏe chủ động: Yêu cầu Kiro xem xét cluster của bạn. Nó kiểm tra CPU so với ngưỡng 60%, so sánh thông lượng với giới hạn instance và gắn cờ các mất cân bằng partition và tắc nghẽn thông lượng trước khi chúng trở thành sự cố.
- Khắc phục sự cố: Độ trễ của consumer tăng đột biến? Power kiểm tra các số liệu liên quan, xác định nguyên nhân gốc rễ (như quyền lãnh đạo partition bị lệch) và hướng dẫn bạn giải quyết.
- Lập kế hoạch dung lượng: Chuẩn bị cho một đợt tăng đột biến lưu lượng truy cập? Power phân tích mức sử dụng hiện tại so với giới hạn instance và đề xuất liệu có nên mở rộng quy mô hay thêm broker.
MSK Express broker power tập hợp tài liệu, số liệu và ngữ cảnh vận hành để tác nhân Kiro của bạn có thể tương quan các phát hiện và giúp xác định nguyên nhân gốc rễ cụ thể cho cơ sở hạ tầng của bạn.
Bắt đầu với MSK Express broker power
Bắt đầu với Kiro powers chỉ mất vài cú nhấp chuột trong Kiro IDE. Bạn có thể cài đặt từ marketplace tích hợp sẵn hoặc nhập từ một URL GitHub công khai. Kiro đóng gói tất cả các thành phần và cung cấp chúng cho tác nhân Kiro.
Để thiết lập MSK Express broker power, hãy làm theo các bước sau:
- Chọn biểu tượng Powers trong thanh bên của Kiro
- Trong bảng điều khiển AVAILABLE, cuộn xuống Build and Operate MSK Express Broker
- Chọn Install
- Power hiện xuất hiện trong bảng điều khiển INSTALLED

Bạn cũng có thể truy cập Kiro powers marketplace để khám phá các powers khác.
Kết luận
MSK Express broker power hợp lý hóa các hoạt động của Kafka bằng cách kết hợp các máy chủ Model Context Protocol (MCP) với hướng dẫn vận hành. Với các tương tác bằng ngôn ngữ tự nhiên, bạn có thể tạo cluster, giám sát tình trạng, tối ưu hóa cấu hình và khắc phục sự cố mà không cần xem xét tài liệu mở rộng.
Tìm hiểu thêm về Kiro và các Kiro powers có sẵn.
Về tác giả
Stephan Schiller

Stephan là Kiến trúc sư Giải pháp tại AWS, nơi anh đã làm việc từ năm 2023. Anh mang đến kinh nghiệm sâu rộng từ các vai trò kỹ thuật trên nhiều hyperscaler và chuyên về phân tích dữ liệu và các hệ thống AI tác nhân. Anh thiết kế và vận hành các nền tảng dữ liệu có khả năng mở rộng và xây dựng các workload tác nhân cho môi trường doanh nghiệp—giúp các tổ chức chuyển từ nguyên mẫu sang các hệ thống AI sẵn sàng sản xuất, đáng tin cậy, an toàn và tích hợp sâu sắc với các hệ sinh thái dữ liệu doanh nghiệp.
TAGS: Amazon MSK