-
Mensageria e Kafka
-
Instalando o Kafka localmente
Link para Dowload do Kafka: https://kafka.apache.org/downloads
Lugar onde se armazena os dados é no zookeeper, download: https://zookeeper.apache.org/releases.html
💡 O Kafka já vêm com o Zookeeperbin/zookeeper-server-start.sh config/zookeeper.properties
bin/kafka-server-start.sh config/server.properties
Criação de um tópico: bin/kafka-topics → caminho do aquivo que será executado — create → Comando de criação —bootstrap-server localhost:9092 → onde o server está rodando —replication-factor 1 → quantidade de replicas de um tópico em brokers diferentes —partitions 1 → quatidade de partições em um tópico —topic Nova_Consulta → nome do tópico
bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic Nova_Consulta
Para saber se o tópico foi criado: bin/kafka-topics → caminho do aquivo que será executado —list → comando de listar —bootstrap-server localhost:9092 → onde o server está rodando
bin/kafka-topics.sh --list --bootstrap-server localhost:9092
Criando podutores: bin/kafka-console-producer.sh → caminho do arquivo que será executado —broker-list localhost:9092 → comando que será executado, apontando o broker que receberá as mensagens —topic Nova_Consulta → nome do tópico que será enviado as mensagens
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic Nova_Consulta
Criando Consumidores: bin/kafka-console-consumer.sh → caminho do arquivo que será executado --bootstrap-server localhost:9092 →Configurações do server onde está as mensagens --topic Nova_Consulta → Tópico que escutaremos --from-beginning → Opicional, caso queira esctutar dês do início
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic Nova_Consulta --from-beginning
-
Notifications
You must be signed in to change notification settings - Fork 0
nathy-mesquita/kafka
Folders and files
Name | Name | Last commit message | Last commit date | |
---|---|---|---|---|
Repository files navigation
About
Projeto de estudo sobre a utilização do Kafka com C#
Topics
Resources
Stars
Watchers
Forks
Releases
No releases published
Packages 0
No packages published