-
Zakładka ZOOKEEPER --> /opt/kafka/bin/zookeeper-server-start.sh /opt/kafka/config/zookeeper.properties
-
Zakładka KAFKA --> /opt/kafka/bin/kafka-server-start.sh /opt/kafka/config/server.properties
-
Zakładka MANAGER tworzenie topicu1 --> /opt/kafka/bin/kafka-topics.sh --create --topic temat_bus01 --bootstrap-server localhost:9092 tworzenie topicu2 --> /opt/kafka/bin/kafka-topics.sh --create --topic temat_tram01 --bootstrap-server localhost:9092 sprawdzanie stanu --> /opt/kafka/bin/kafka-topics.sh --describe --topic temat_bus01 --bootstrap-server localhost:9092
-
Zakładka CONSUMER TOPIC1 --> /opt/kafka/bin/kafka-console-consumer.sh --topic temat_bus01 --bootstrap-server localhost:9092
-
Zakładka PRODUCENT TOPIC1 --> /opt/kafka/bin/kafka-console-producer.sh --topic temat_bus01 --bootstrap-server localhost:9092
-
Zakładka CONSUMER TOPIC2 --> /opt/kafka/bin/kafka-console-consumer.sh --topic temat_tram01 --bootstrap-server localhost:9092
-
Zakładka PRODUCENT TOPIC2 --> /opt/kafka/bin/kafka-console-producer.sh --topic temat_tram01 --bootstrap-server localhost:9092
-
Notifications
You must be signed in to change notification settings - Fork 0
Oskarovsky/KafkaFlinkScala
Folders and files
| Name | Name | Last commit message | Last commit date | |
|---|---|---|---|---|
Repository files navigation
About
No description, website, or topics provided.
Resources
Stars
Watchers
Forks
Releases
No releases published
Packages 0
No packages published