O Message Queue for Apache Kafka oferece SDKs para diversas linguagens de programação para facilitar o envio e o recebimento de mensagens.
Introdução
Um SDK (Software Development Kit) inclui exemplos, bibliotecas, cadeias de ferramentas e scripts de build. Você pode desenvolver e compilar aplicações diretamente no ambiente do SDK sem configurações adicionais.
SDKs
O Message Queue for Apache Kafka
fornece SDKs para as seguintes linguagens de programação. Use estes links para consultar históricos de atualizações, baixar pacotes de instalação e acessar a documentação de referência.
| SDK | Demo | Protocolo compatível | Referência | Arquivo README |
| Java SDK | Java SDK Demo |
|
Enviar e receber mensagens usando um endpoint de instância | README.md |
| Python SDK | Python SDK Demo |
|
Enviar e receber mensagens usando o Python SDK | |
| C++ SDK | C++ SDK Demo |
|
Enviar e receber mensagens usando o C++ SDK | |
| Go SDK | Go SDK Demo |
|
Enviar e receber mensagens usando o Go SDK | README.md |
| PHP SDK | PHP SDK Demo |
|
Enviar e receber mensagens usando o PHP SDK | |
| Ruby SDK | Ruby SDK Demo |
|
Enviar e receber mensagens usando o Ruby SDK | README.md |
| Node.js SDK | Node.js SDK Demo |
|
Enviar e receber mensagens usando o Node.js SDK | README.md |
| C# SDK | N/A |
|
Enviar e receber mensagens usando o C# SDK | README.md |
Observações de uso
Endpoints de instância
Seu cliente se conecta ao Message Queue for Apache Kafka por meio de diferentes endpoints para enviar e receber mensagens.
Default Endpoint: Conecta clientes a uma instância do Message Queue for Apache Kafka para enviar e receber mensagens.
-
SSL Endpoint: Conecte-se a uma instância do Message Queue for Apache Kafka via SSL e use o mecanismo PLAIN para autenticação. O PLAIN é um método de autenticação por nome de usuário e senha. O Message Queue for Apache Kafka otimiza o mecanismo PLAIN para permitir a adição dinâmica de usuários SASL sem reiniciar a instância.
ImportanteSe sua instância usar um certificado SSL de 1024 bits e você precisar de mais segurança, atualize-o para um certificado de 4096 bits. Para obter mais informações, consulte
Fazer upgrade do algoritmo de certificado SSL
.
-
SASL Endpoint: Em uma VPC, conecte-se ao Message Queue for Apache Kafka usando um endpoint SASL e use o mecanismo PLAIN ou SCRAM para enviar e receber mensagens. O SASL oferece suporte aos seguintes mecanismos de autenticação:
PLAIN: Método de autenticação por nome de usuário e senha. O mecanismo PLAIN no Message Queue for Apache Kafka permite adicionar usuários SASL dinamicamente sem reiniciar a instância.
SCRAM-SHA-256 do Message Queue for Apache Kafka: Mecanismo de autenticação seguro que usa algoritmos de hash no cliente e no servidor para verificar credenciais. Esse mecanismo oferece maior segurança que o PLAIN e também permite adicionar usuários SASL dinamicamente sem reiniciar a instância.
Para obter mais informações sobre endpoints, consulte Comparação de endpoints.
Uso de demos
Selecione a demo correspondente à sua instância, configure o arquivo da demo e execute-o para enviar e receber mensagens. Para obter instruções detalhadas, consulte a documentação de cada linguagem.
Referências
Implante uma instância do Message Queue for Apache Kafka Message Queue for Apache Kafka com base no tipo de rede necessário. Para obter mais informações, consulte Conectar-se a uma instância do Message Queue for Apache Kafka via VPC e Implantar uma instância acessível pela internet e por VPC.
Crie o grupo de consumidores e o tópico necessários. Para obter mais informações, consulte Etapa 3: Criar recursos.
O usuário SASL padrão para uma instância de internet ou VPC fornece apenas verificação de identidade. Ele tem permissões de leitura e gravação para todos os tópicos e grupos de consumidores. Para um controle de acesso mais granular, ative o recurso ACL para criar usuário s SASL e conceder permissões específicas a eles. A ativação do recurso ACL revoga as permissões do usuário SASL padrão. Para obter mais informações, consulte Conceder permissões a usuários SASL.