This topic describes the release notes of Message Queue for Apache Kafka.

2021-12-15

FeatureDescriptionTypeReferences
Endpoints of the domain name typeDomain names can be used as endpoints to access Message Queue for Apache Kafka instances. Added featureView endpoints

2021-11-25

FeatureDescriptionTypeReferences
AnalyticDB Sink ConnectorData can be exported from a topic of a Message Queue for Apache Kafka instance to AnalyticDB for MySQL or AnalyticDB for PostgreSQL by using Function Compute. Added featureCreate an AnalyticDB sink connector

2021-11-22

FeatureDescriptionTypeReferences
Tablestore Sink ConnectorData can be exported from a topic of a Message Queue for Apache Kafka instance to Tablestore. Added featureCreate a Tablestore sink connector

2021-11-18

FeatureDescriptionTypeReferences
New regionMessage Queue for Apache Kafka is available in the China (Guangzhou) region. Added feature

2021-09-07

FeatureDescriptionTypeReferences
Extract, transform, and load (ETL) task managementData in Message Queue for Apache Kafka instances can be extracted, transformed, and loaded by using ETL tasks. Added featureManage ETL tasks

2021-08-24

FeatureDescriptionTypeReferences
DLA Sink ConnectorData can be synchronized from Message Queue for Apache Kafka to Data Lake Analytics (DLA). Added featureCreate a DLA sink connector
Automatic group creationAutomatic creation of consumer groups can be enabled in the Message Queue for Apache Kafka console.Added featureUse the flexible group creation feature

2021-08-05

FeatureDescriptionTypeReferences
Synchronization of data from MySQL databases to Message Queue for Apache Kafka by using CanalThe Canal framework can be used to synchronize data from MySQL databases to Message Queue for Apache Kafka. Added featureUse Canal to synchronize data from a MySQL database to Message Queue for Apache Kafka

2021-07-09

FeatureDescriptionTypeReferences
Message sending and receiving by using Spring CloudThe Spring Cloud framework can be used to access Message Queue for Apache Kafka and send and receive messages. Added featureUse the Spring Cloud framework to send and subscribe to messages

2021-06-25

FeatureDescriptionTypeReferences
Updated consoleThe Message Queue for Apache Kafka console is updated to improve user experience. Optimized feature

2021-03-24

FeatureDescriptionTypeReferences
Elasticsearch Sink ConnectorData can be synchronized from Message Queue for Apache Kafka to Elasticsearch. Added featureCreate an Elasticsearch sink connector

2021-03-15

FeatureDescriptionTypeReferences
MySQL Source ConnectorData can be synchronized from ApsaraDB RDS for MySQL to Message Queue for Apache Kafka.
Note This feature is available only in the following regions: China (Shenzhen), China (Chengdu), China (Beijing), China (Hangzhou), and China (Shanghai).
Added featureCreate a MySQL source connector

2021-03-03

FeatureDescriptionTypeReferences
OSS Sink ConnectorData can be synchronized from Message Queue for Apache Kafka to Object Storage Service (OSS). Added featureCreate an OSS sink connector

2020-12-14

FeatureDescriptionTypeReferences
ConnectorThe number of concurrent consumption threads can be configured for a Function Compute sink connector. Optimized featureCreate a Function Compute sink connector

2020-11-30

FeatureDescriptionTypeReferences
Service-linked role
  • The AliyunServiceRoleForAlikafkaConnector service-linked role is added. This role can be used to implement the Function Compute sink connector feature.
  • The AliyunServiceRoleForAlikafkaConnector service-linked role can be automatically created when a Function Compute sink connector is created in the Message Queue for Apache Kafka console.
Added feature
ConnectorConnectors can be tested in the console. Added featureManage a connector

2020-11-18

FeatureDescriptionTypeReferences
Connector
  • Function Compute sink connector:
    • The maximum number of retries that can be performed after a message fails to be sent can be specified.
    • The fail and log policies are provided for handling message sending failures.
  • MaxCompute sink connector:
    • AccessKey authentication is no longer supported.
    • Security Token Service (STS) authentication is supported.
    • Message modes such as DEFAULT, VALUE, and KEY are supported.
    • Message formats such as TEXT, BINARY, and CSV are supported.
    • Data granularity levels such as DAY, HOUR, and MINUTE are supported.
    • The time zone in which a Message Queue for Apache Kafka producer resides can be specified.
Optimized feature
ACLThe ACL feature can be enabled in the Message Queue for Apache Kafka console. You no longer need to submit a ticket to apply to use the feature. Optimized featureGrant permissions to SASL users

2020-10-22

FeatureDescriptionTypeReferences
Connector
  • The connector feature can be enabled in the Message Queue for Apache Kafka console.
  • The connector feature is available in regions such as China (Zhangjiakou), China (Hohhot), and China (Hong Kong).
  • The connector feature can be enabled for Message Queue for Apache Kafka instances whose major version is 0.10.2 and minor version is the latest.
  • Topics and consumer groups that are required by a connector can be automatically created and deleted.
  • Connectors can be suspended and resumed.
  • After a connector is created, it can enter the Running state only after you manually deploy the connector.
  • The interaction design for connectors in the Message Queue for Apache Kafka console is optimized.
Optimized feature

2020-08-20

FeatureDescriptionTypeReferences
GetConsumerListA response parameter is added to indicate the description of a group. Optimized featureGetConsumerList

2020-07-29

FeatureDescriptionTypeReferences
Specification evaluationAppropriate editions of Message Queue for Apache Kafka instances are recommended based on the specifications of self-managed Kafka clusters. Added featureEvaluate instance specifications
Display of the migration progressThe migration progress of a self-managed Kafka cluster can be viewed. Added featureView the migration progress

2020-07-22

FeatureDescriptionTypeReferences
GetInstanceListResponse parameters are added to indicate the information for multi-zone deployment and custom security groups. Optimized featureGetInstanceList

2020-07-15

FeatureDescriptionTypeReferences
Security group configuration by using TerraformTerraform can be used to configure a security group when you create a Message Queue for Apache Kafka instance. Added featurealicloud_alikafka_instance

2020-06-19

FeatureDescriptionTypeReferences
ConnectorThe connector feature is provided. You can use connectors to connect Message Queue for Apache Kafka to other Alibaba Cloud services and synchronize data between Message Queue for Apache Kafka and other Alibaba Cloud services. Added featureOverview

2020-05-20

FeatureDescriptionTypeReferences
Changed version namesThe open source version is changed to the major version, and the internal version is changed to the minor version. The major version corresponds to the open source version, and the minor version is an optimized internal version of the major version. Optimized featureUpgrade the versions of instances
Display of the upgrade progressThe remaining time and progress of an instance upgrade task can be viewed after the upgrade task is initiated. Added featureUpgrade the versions of instances
Display of the number of topics that you can createThe number of topics that you can create can be viewed.
  • Professional Edition instance: The number of topics that you can create is twice the number of topics that you purchase. For example, if you purchase 50 topics for a Professional Edition instance, you can create 100 topics.
  • Standard Edition instance: The number of topics that you can create equals the number of topics that you purchase. For example, if you purchase 50 topics for a Standard Edition instance, you can create 50 topics.
Added featureNone
Display of task execution recordsExecution records can be viewed for the following tasks: upgrading instance versions, modifying message configurations, upgrading instance configurations, and enabling the ACL feature. Added featureView task execution records

2020-05-13

FeatureDescriptionTypeReferences
Scale-outThe cluster that corresponds to a Message Queue for Apache Kafka instance can be scaled out. When you upgrade the traffic specification of an instance, a cluster scale-out operation may be triggered. After the cluster is scaled out, you must rebalance the topic traffic so that the topic traffic can be evenly distributed among the brokers in the cluster. Added feature

2020-05-12

FeatureDescriptionTypeReferences
New regionsMessage Queue for Apache Kafka is available in the China (Heyuan) and China (Chengdu) regions. Added featureNone

2020-04-08

FeatureDescriptionTypeReferences
ACLThe ACL feature can be enabled. This feature allows you to grant permissions to Simple Authentication and Security Layer (SASL) users. Added featureGrant permissions to SASL users

2020-04-02

FeatureDescriptionTypeReferences
Message retention periodThe maximum retention period of a message on a broker is increased from 168 hours to 480 hours. Optimized featureModify configurations for messages

2020-03-02

FeatureDescriptionTypeReferences
GetAllowedIpListThe GetAllowedIpList operation is supported. This operation can be called to query the IP address whitelists of an instance. Added featureGetAllowedIpList
UpdateAllowedIpThe UpdateAllowedIp operation is supported. This operation can be called to update an IP address whitelist. Added featureUpdateAllowedIp