# Instalação do Servidor Apache Kafka no windows ### Programas para instalar: ![](https://i.imgur.com/3nkxlgK.png) ![](https://i.imgur.com/1YfllCI.png) ![](https://i.imgur.com/Ye1tq21.png) * Java JDK 8 :arrow_right: http://www.oracle.com/technetwork/java/javase/downloads/jre8-downloads-2133155.html * Apache Kafka :arrow_right: http://kafka.apache.org/downloads.html * Apache Zookeeper :arrow_right: http://zookeeper.apache.org/releases.html Descompactar os arquivo do Kafka e do Zookeeper no diretorio `C:` ### Instalação do ZooKeeper :arrow_right: Entrar na pasta `conf` e renomear o arquivo `zoo_sample.cfg`para `zoo.cfg` ![](https://i.imgur.com/7BljfY2.png) . :arrow_right: Editar o arquivo `zoo.cfg` :arrow_right: Na linha: `dataDir=/tmp/zookeeper` mudar para `C:\Zookeeper-3.5.9\data` (caminho onde está descompactado o seu zookeeper) :arrow_right: Criar variável de ambiente `ZOOKEEPER_HOME = C:\Zookeeper-3.5.9` ![](https://i.imgur.com/yJd0aU9.png) . :arrow_right: Incluir no path o caminho: `%ZOOKEEPER_HOME%\bin` ![](https://i.imgur.com/FhlHMNU.png) . :arrow_right: Porta padrão do Zookeeper: 2181 :arrow_right: Execute o ZooKeeper abrindo um terminal cmd e digite **zkserver**. ![](https://i.imgur.com/qogiU8d.png) . ### Instalação do Kafka :arrow_right: Entrar na pasta `conf`. :arrow_right: Editar o arquivo `server.properties` :arrow_right: Na linha: `log.dirs=/tmp/kafka-logs` mudar para `log.dirs=C:/Kafka_2.12/kafka-logs` :exclamation: Atenção ao lado das barras :exclamation: :arrow_right: Verificar se o zookeeper está iniciado. Execute o ZooKeeper abrindo um terminal cmd e digite **zkserver**. :arrow_right: Criar as pastas: `kafka-logs` e `zookeeper` :arrow_right: Abrir um terminal CMD dentro do diretório do kafka ![](https://i.imgur.com/qoJ7IHX.png) . :arrow_right: Digitar: `.\bin\windows\kafka-server-start.bat .\config\server.properties`, Clicar ENTER. ![](https://i.imgur.com/LnXC83m.png) . ### Criar um teste com o Kafka :arrow_right: Na pasta: `C:\kafka-2.8.0\bin\windows`, abrir um terminal CMD. :arrow_right: Digitar o comando: `kafka-topics.bat --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test` ![](https://i.imgur.com/cckw0LM.png) . ### Criação de um produtor para servidor de teste :arrow_right: Dentro da pasta: `C:\kafka_2.11-0.9.0.0\bin\windows`, abrir um terminal CMD. :arrow_right: Para iniciar um produtor, Digitar o comando: `kafka-console-producer.bat --broker-list localhost:9092 --topic test` ![](https://i.imgur.com/GIcs3wv.png) . ### Criação de um consumidor para servidor de teste :arrow_right: Dentro da pasta: `C:\kafka_2.11-0.9.0.0\bin\windows`, abrir um ==NOVO== terminal CMD. :arrow_right: Digitar o comando: `kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test` ![](https://i.imgur.com/cjWvyvv.png) . :arrow_right: O prompt do terminal ficará preso aguardando receber uma mensagem. :arrow_right: Digitar uma mensagem no terminal do produtor. ![](https://i.imgur.com/ToVBvFK.png) . :arrow_right: Será recebido no terminal do consumidor. ![](https://i.imgur.com/9Z1SOMA.png) . :point_right: Enviado. ![](https://i.imgur.com/hgFWtQy.png) . :point_right: Recebido. ![](https://i.imgur.com/311hR4F.png) ### Comandos úteis * **Tópicos da lista:** `kafka-topics.bat --list --zookeeper localhost:2181` * **Descrição do tópico:** `kafka-topics.bat --describe --zookeeper localhost:2181 --topic [Topic Name]` * **Ler as mensagens desde o início:** `kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic [Topic Name] --from-beginn` * **Excluir Tópico:** `kafka-run-class.bat kafka.admin.TopicCommand --delete --topic [topic_to_delete] --zookeeper localhost:2181` ###### tags: `kafka` `java` `instalação`