Document Center
Message Queue for Apache Kafka
Announcements
Announcement
Release notes
Introduction
What is Message Queue for Apache Kafka?
Architecture
Benefits
Scenarios
Terms
Limits
Comparison between Message Queue for Apache Kafka and open source Apache Kafka
Comparison among endpoints
Storage engine comparison
Pricing
Billing
Billing FAQ
Permissions
Access control overview
RAM policies
Grant permissions to RAM users
Grant permissions across Alibaba Cloud accounts
Service-linked roles
Authorize SASL users
Quick-start
Overview
Step 1: Obtain the access permissions
Step 2: Purchase and deploy an instance
Access from a VPC
Access from the Internet and a VPC
Step 3: Create resources
Step 4: Use the SDK to send and subscribe to messages
Use the default endpoint to send and subscribe to messages
Send and subscribe to messages by using an SSL endpoint with PLAIN authentication
Console Guide
Instances
View endpoints
Upgrade instance specifications
Modify the message configurations
Upgrade the instance version
Configure the whitelist
Rebalance the topic traffic
View task execution records
Instances
Topics
View partition status
FAQ
Consumer Group
Reset consumer offsets
View consumption status
FAQ
Tags
Monitoring and alerting
Monitor resources and generate alerts
FAQ
Connectors
Overview
Enable the connector feature
Create a connector
Create a Function Compute sink connector
Create a Function Compute sink connector
Create a MaxCompute sink connector
Create an OSS sink connector
Create an Elasticsearch sink connector
Create a MySQL source connector
View task configurations of a connector
View connector logs
Suspend a connector
Resume a connector
Delete a connector
Modify connector configurations
Test a connector
Enable Internet access for a connector
Migration
Overview
Evaluate specifications
Migrate topics
Migrate topic metadata from a self-managed Apache Kafka cluster to Message Queue for Apache Kafka
Migrate topic metadata between Message Queue for Apache Kafka instances
Migrate consumer groups
Migrate consumer group metadata from a self-managed Apache Kafka cluster to Message Queue for Apache Kafka
Migrate consumer group metadata between Message Queue for Apache Kafka instances
Migrate data
Migrate data to the cloud
View the migration progress
Query messages
SDK reference
SDK overview
SDK for Java
Overview
Send and subscribe to messages by using the default endpoint
Send and subscribe to messages by using an SSL endpoint with PLAIN authentication
Send and subscribe to messages by using an SASL endpoint with PLAIN authentication
Send and subscribe to messages by using an SASL endpoint with SCRAM authentication
Use the Spring Cloud framework to send and subscribe to messages
SDK for Python
Overview
Send and subscribe to messages by using the default endpoint
Send and subscribe to messages by using an SSL endpoint with PLAIN authentication
SDK for C++
Overview
Use the default endpoint to send and subscribe to messages
Send and subscribe to messages by using an SSL endpoint with PLAIN authentication
SDK for Go
Overview
Send and consume messages by using the default endpoint
Send and subscribe to messages by using an SSL endpoint with PLAIN authentication
Send and subscribe to messages by using an SASL endpoint with PLAIN authentication
Send and subscribe to messages by using an SASL endpoint with SCRAM authentication
SDK for PHP
Overview
Use the default endpoint to send and subscribe to messages
Send and subscribe to messages by using an SSL endpoint with PLAIN authentication
SDK for Ruby
Overview
Use the default endpoint to send and subscribe to messages
Send and subscribe to messages by using an SSL endpoint with PLAIN authentication
SDK for Node.js
Overview
Send and consume messages by using the default endpoint
Send and subscribe to messages by using an SSL endpoint with PLAIN authentication
C# SDK
Overview
Use the default endpoint to send and receive messages
Send and subscribe to messages by using an SSL endpoint with PLAIN authentication
Use the PLAIN mechanism to send and receive messages over an SASL endpoint
Use the SCRAM mechanism to send and receive messages over an SASL endpoint
Sending on clients
Consumption on clients
API reference
List of operations by function
Release notes
Make API requests
Obtain an SDK
Sample requests
Endpoints
Signature method
Common parameters
Obtain an AccessKey pair
Instances
CreatePrePayOrder
StartInstance
UpgradePrePayOrder
ModifyInstanceName
GetInstanceList
DeleteInstance
GetAllowedIpList
UpdateAllowedIp
UpdateInstanceConfig
UpgradeInstanceVersion
Topic
CreateTopic
DeleteTopic
GetTopicList
GetTopicStatus
ModifyPartitionNum
ModifyTopicRemark
Consumer groups
DeleteConsumerGroup
GetConsumerList
GetConsumerProgress
CreateConsumerGroup
Tags
UntagResources
TagResources
ListTagResources
SASL users
CreateSaslUser
DeleteSaslUser
DescribeSaslUsers
SASL ACL
CreateAcl
DeleteAcl
DescribeAcls
Cloud Monitor resource reports
Cloud Monitor resource statistics
DescribeMetricMetaList
DescribeMetricLast
DescribeMetricList
DescribeMetricTop
DescribeMetricData
DescribeProjectMeta
Ecosystem
Ecosystem overview
Open source ecosystem
Logstash
Connect Message Queue for Apache Kafka to Logstash
VPC
Connect a Message Queue for Apache Kafka instance to Logstash as an input
Connect a Message Queue for Apache Kafka instance to Logstash as an output
Internet
Connect a Message Queue for Apache Kafka instance to Logstash as an input
Connect a Message Queue for Apache Kafka instance to Logstash as an output
Filebeat
Connect Message Queue for Apache Kafka to Filebeat
VPC
Connect a Message Queue for Apache Kafka instance to Filebeat as an input
Connect a Message Queue for Apache Kafka instance to Filebeat as an output
Internet
Connect a Message Queue for Apache Kafka instance to Filebeat as an input
Connect a Message Queue for Apache Kafka instance to Filebeat as an output
What can I do if Filebeat fails to send a message to a topic in Message Queue for Apache Kafka?
Use Kafka Connect to synchronize data from a MySQL database to Message Queue for Apache Kafka
Use Canal to synchronize data from a MySQL database to Message Queue for Apache Kafka
Use Kafka Connect to synchronize data from an SQL Server database to Message Queue for Apache Kafka
Best practices
Best practices for producers
Best practices for subscribers
FAQ
Videos
Terms
Message Queue for Apache Kafka SLA
All Products
Search
Document Center
Message Queue for Apache Kafka
Pricing
Billing FAQ
This Product
This Product
All Products
Message Queue for Apache Kafka
Why am I charged by peak traffic?
What is the basis for billing by peak traffic?
Why am I charged for additional topics?
How am I billed if I use the connector feature?
Free Trial
Free Trial