Start ZooKeeper, run CMD and type
zkserver
E:\kafka\kafka_2.12-2.3.0
en run
.\> \ Windows \kafka-server-start.bat.\config\server.properties
CMD
: \kafka\kafka_2.12-2.3.0
<>> kafka-t>s. Bat –create –zookeeper localhost:2181 –replication-factor 1 –partitions 1-topic test
Producer
run CMD, enter kafka bin\ Windows folder
: \kafka\kafka_2.12-2.3.0\bin\ Windows
t>run
kafka-c>le-producer.bat — broke-list localhost:9092 –topic test
E:\kafka\kafka_2.12-2.3.0\bin\ Windows
en run
k>-console-consumer.bat –bootstrap-server localhost:9092 –topic test –from — beginning
Read More:
- Kafka : WARN Error while fetching metadata with correlation id xx : {=UNKNOWN_TOPIC_OR_PARTITION}
- Mistakes in learning Flink programming
- kafka-eagle-2.0.3：Note: Kafka version is – or JMX Port is -1 maybe kafka broker jmxport disable.
- Python implements inserting content in the specified position of text
- Centos7 installing Kafka
- Kafka connection abnormal org.apache.kafka . common.errors.TimeoutException : Failed to update metadata after 60000 ms.
- Starting zookeeper to report an error already running as process
- Zookeeper will not attempt to authenticate using SASL (unknown error)
- Starting zookeeper… Already running as process 1949
- The first installation of zookeeper on Linux failed to start
- Error in brew install: curl: (22) the requested URL returned error: 404 Not Found
- Solve the problem of unable to start under zookeeper Linux
- Installing zookeeper under Linux system
- module ‘tensorflow_core._api.v2.train’ has no attribute ‘slice_input_producer’
- IntegrityError at ** NOT NULL constraint failed: learning_logs_topic.owner_id
- Ubuntu (16.04) creates a Windows boot U disk, using woeusb instead of DD
- Error analysis of multiple linear regression in R language model.frame.default
- Error 1045 (28000): solution to access denied for user ‘root’ @’localhost ‘(using password: no)
- Start gzip in node environment of project optimization
- No provider available from registry 192.168.124.195:2181 for service cn.sofw