18 câu hỏi0s
1
Một shard Kinesis (provisioned) hỗ trợ throughput ghi tối đa:
2
3 ứng dụng consumer cùng đọc 1 stream, mỗi app cần đủ 2MB/s per shard và latency thấp. Giải pháp?
3
Producer bị ProvisionedThroughputExceededException dù tổng traffic dưới tổng capacity. Nguyên nhân khả dĩ nhất?
4
Metric nào cho biết consumer đang tụt hậu so với producer?
5
Traffic sự kiện rất gai và không dự đoán được, team không muốn quản lý resharding. Cấu hình Kinesis nào?
6
Đặc điểm nào ĐÚNG về Amazon Data Firehose?
7
Streaming JSON cần lưu S3 dạng Parquet cho Athena, ít vận hành nhất. Giải pháp?
8
Firehose ghi vào Redshift theo cơ chế nào?
9
Lambda transform trong Firehose đánh dấu một số record ProcessingFailed. Chuyện gì xảy ra?
10
Công ty chạy Apache Kafka tự quản, muốn lên AWS với thay đổi code tối thiểu. Giải pháp?
11
Trong Kafka, thứ tự message được đảm bảo ở phạm vi nào?
12
Cần CDC từ PostgreSQL vào Kafka topic, không tự vận hành Connect worker. Dịch vụ?
13
Phương án authentication nào dùng được trên MSK Serverless?
14
"Tính doanh thu 15 phút gần nhất, cập nhật mỗi 5 phút" — loại window?
15
Gom event theo phiên người dùng, phiên đóng khi idle 20 phút. Công cụ phù hợp nhất?
16
Flink đảm bảo exactly-once processing nhờ cơ chế nào?
17
Yêu cầu: mỗi message được đúng một worker xử lý rồi xóa, không cần replay, không cần ordering. Dịch vụ?
18
Chọn đúng cặp dịch vụ cho 2 nhu cầu: (1) deliver log vào OpenSearch gần realtime, ít vận hành; (2) realtime anomaly detection có state trên stream giao dịch.