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
      • Instance editions
      • Comparison among endpoints
      • Storage engine comparison
    • Pricing
      • Billing
      • Subscription
        • Billing rules
        • Overdue payments
        • Instance renewal
      • Set the notification policy for imminent overdue payments and instance release
      • View billing and usage details
      • Billing FAQ
    • Permissions
      • Access control overview
      • RAM policies
      • Grant permissions to RAM users
      • Grant permissions across Alibaba Cloud accounts
      • Service-linked roles
      • Grant permissions to 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
      • Perform health self-check on instances
    • 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
        • Automatically create groups
        • Instances
      • Topics
        • View partition status
        • FAQ
      • Consumer Group
        • Reset consumer offsets
        • View the consumption details
        • FAQ
      • Manage tags
      • Monitoring and alerting
        • Monitoring and alerting
        • Monitoring and alerting
        • FAQ
      • Connectors
        • Overview
        • Enable the connector feature
        • Create a 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
          • Create a DLA sink 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
      • Manage ETL tasks
      • 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 consume messages by using the default endpoint
        • Send and consume messages by using an SSL endpoint with PLAIN authentication
        • Send and consume messages by using an SASL endpoint with PLAIN authentication
        • Send and consume messages by using an SASL endpoint with SCRAM authentication
        • Use the Spring Cloud framework to send and consume messages
      • SDK for Python
        • Overview
        • Send and consume messages by using the default endpoint
        • Send and consume messages by using an SSL endpoint with PLAIN authentication
      • SDK for C++
        • Overview
        • Send and consume messages by using the default endpoint
        • Send and consume messages by using an SSL endpoint with PLAIN authentication
      • SDK for Go
        • Overview
        • Send and consume messages by using the default endpoint
        • Send and consume messages by using an SSL endpoint with PLAIN authentication
        • Send and consume messages by using an SASL endpoint with PLAIN authentication
        • Send and consume messages by using an SASL endpoint with SCRAM authentication
      • SDK for PHP
        • Overview
        • Send and consume messages by using the default endpoint
        • Send and consume messages by using an SSL endpoint with PLAIN authentication
      • SDK for Ruby
        • Overview
        • Send and consume messages by using the default endpoint
        • Send and consume 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 consume messages by using an SSL endpoint with PLAIN authentication
      • C# SDK
        • Overview
        • Send and consume messages by using the default endpoint
        • Send and consume messages by using an SSL endpoint with PLAIN authentication
        • Send and consume messages by using an SASL endpoint with PLAIN authentication
        • Send and consume messages by using an SASL endpoint with SCRAM authentication
      • 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
        • UpgradePostPayOrder
        • 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
        • CloudMonitor 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 consumers
    • FAQ
    • Videos
    • Terms
      • Message Queue for Apache Kafka SLA
 
All Products
Search
  • Document Center
  • Message Queue for Apache Kafka
  • API Reference
  • Obtain an SDK

This Product

  • This Product
  • All Products

    Obtain an SDK

    Document Center

    Obtain an SDK

    Last Updated: Sep 23, 2020

    This topic describes how to obtain a Message Queue for Apache Kafka SDK.

    Message Queue for Apache Kafka provides SDKs in the following programming languages.

    Language SDK
    Java Aliyun Java SDK Alikafka
    Go Aliyun Go SDK Alikafka
    PHP Aliyun PHP SDK Alikafka

    How helpful was this page?

    What might be the problems?

      More suggestions?

      Thank you! We've received your feedback.