Fluxo de dados com os Hubs de Eventos usando o protocolo KafkaData streaming with Event Hubs using the Kafka protocol

Este guia de início rápido mostra como transmitir para o Kafka habilitado dos Hubs de Eventos sem alterar seus clientes de protocolo ou seus próprio clusters em execução.This quickstart shows how to stream into Kafka-enabled Event Hubs without changing your protocol clients or running your own clusters. Você aprenderá a usar seu produtores e os consumidores para se comunicar com os Hubs de Eventos habilitados com Kafka com apenas uma alteração de configuração nos seus aplicativos.You learn how to use your producers and consumers to talk to Kafka-enabled Event Hubs with just a configuration change in your applications. Hubs de Eventos do Azure dá suporte para Apache Kafka versão 1.0.Azure Event Hubs supports Apache Kafka version 1.0.

Observação

Este exemplo está disponível no GitHubThis sample is available on GitHub

Pré-requisitosPrerequisites

Para concluir este início rápido, você precisa atender aos seguinte pré-requisitos:To complete this quickstart, make sure you have the following prerequisites:

Criar um Kafka habilitado com o namespace dos Hubs de EventoCreate a Kafka enabled Event Hubs namespace

  1. Entre no portal do Azure e clique em Criar um recurso no canto superior esquerdo da tela.Sign in to the Azure portal, and click Create a resource at the top left of the screen.

  2. Pesquisar os Hubs de eventos e selecionar as opções mostradas aqui:Search for Event Hubs and select the options shown here:

    Exportar para Hubs de Eventos no portal

  3. Forneça um nome exclusivo e habilite o Kafka no namespace.Provide a unique name and enable Kafka on the namespace. Clique em Criar.Click Create. Observação: Só há suporte para os Hubs de Eventos para Kafka nos Hubs de Eventos das camadas Standard e Dedicado.Note: Event Hubs for Kafka is only supported by Standard and Dedicated tier Event Hubs. Os Hubs de Eventos da camada Básica retornarão um Erro de Autorização do Tópico em resposta a todas as operações do Kafka.Basic tier Event Hubs will return a Topic Authorization Error in response to any Kafka operations.

    Criar um namespace

  4. Depois que o namespace foi criado, na guia Configurações, clique em Políticas de acesso compartilhado para obter a cadeia de conexão.Once the namespace is created, on the Settings tab click Shared access policies to get the connection string.

    Clique em Políticas de acesso compartilhado

  5. Você pode escolher o padrão RootManageSharedAccessKey, ou adicionar uma nova política.You can choose the default RootManageSharedAccessKey, or add a new policy. Clique no nome da política e copie a cadeia de conexão.Click the policy name and copy the connection string.

    Selecione uma política

  6. Adiciona esta cadeia de conexão à sua configuração de aplicativo Kafka.Add this connection string to your Kafka application configuration.

Agora você pode transmitir eventos de aplicativos que usam o protocolo Kafka nos Hubs de eventos.You can now stream events from your applications that use the Kafka protocol into Event Hubs.

Enviar e receber mensagens com Kafka no Hubs de EventoSend and receive messages with Kafka in Event Hubs

  1. Clone o repositório de Hubs de Eventos do Azure para Kafka.Clone the Azure Event Hubs for Kafka repository.

  2. Navegue até azure-event-hubs-for-kafka/quickstart/java/producer.Navigate to azure-event-hubs-for-kafka/quickstart/java/producer.

  3. Atualize os detalhes de configuração para o produtor no src/main/resources/producer.config da seguinte maneira:Update the configuration details for the producer in src/main/resources/producer.config as follows:

    bootstrap.servers={YOUR.EVENTHUBS.FQDN}:9093
    security.protocol=SASL_SSL
    sasl.mechanism=PLAIN
    sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="$ConnectionString" password="{YOUR.EVENTHUBS.CONNECTION.STRING}";
    
  4. Execute o código de produtor e fluxo nos Hubs de Eventos habilitado com Kafka:Run the producer code and stream into Kafka-enabled Event Hubs:

    mvn clean package
    mvn exec:java -Dexec.mainClass="TestProducer"                                    
    
  5. Navegue até azure-event-hubs-for-kafka/quickstart/java/consumer.Navigate to azure-event-hubs-for-kafka/quickstart/java/consumer.

  6. Atualize os detalhes de configuração para o consumidor no src/main/resources/consumer.config da seguinte maneira:Update the configuration details for the consumer in src/main/resources/consumer.config as follows:

    bootstrap.servers={YOUR.EVENTHUBS.FQDN}:9093
    security.protocol=SASL_SSL
    sasl.mechanism=PLAIN
    sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="$ConnectionString" password="{YOUR.EVENTHUBS.CONNECTION.STRING}";
    
  7. Execute o código do consumidor e processo a partir do Hubs de Eventos habilitados com Kafka usando seus clientes Kafka:Run the consumer code and process from Kafka enabled Event Hubs using your Kafka clients:

    mvn clean package
    mvn exec:java -Dexec.mainClass="TestConsumer"                                    
    

Se seu cluster Kafka de Hubs de Eventos tiver eventos, inicie agora recebendo-os do consumidor.If your Event Hubs Kafka cluster has events, you now start receiving them from the consumer.

Próximas etapasNext steps

Neste artigo, você aprendeu como transmitir para os Hubs de Eventos com Kafka habilitado sem alterar seus clientes de protocolo ou seus próprios clusters em execução.In this article, you learned how to stream into Kafka-enabled Event Hubs without changing your protocol clients or running your own clusters. Para saber mais, continue com o tutorial a seguir:To learn more, continue with the following tutorial: