Kafka_1 | WARN Client session timed out, have not heard from server in 6127ms for sessionid 0x16fcd000c600001 () Kafka_1 | INFO Socket connection established to zookeeper/172.24.0.2:2181, initiating session () Kafka_1 | WARN Attempting to send response via channel for which there is no open connection, connection id 172.24.0.6:19092-172.24.0.9:46802-22 () Kafka_1 | WARN Attempting to send response via channel for which there is no open connection, connection id 172.24.0.6:19092-172.24.0.9:46752-21 () Kafka_1 | WARN Attempting to send response via channel for which there is no open connection, connection id 172.24.0.6:19092-172.24.0.7:51372-21 () Will not attempt to authenticate using SASL (unknown error) () Kafka_1 | INFO Opening socket connection to server zookeeper/172.24.0.2:2181. However, when I try to run docker-compose up the connect service doesn’t start properly and I’m getting an empty response from the server when running any command like this: curl localhost:8083/ mvn clean install -DskipTests worked fine. If you can see the outputs kafka is set up and running neatly on you M1 system.I’m using docker-compose from kafka-connect-zeebe following the the install guide. $ kafka-console-consumer -bootstrap-server localhost:9092 -topic foobar -from-beginning foo bar This will listen to the bootstrap server at port 9092 at topic foobar: In the second one initalize a consumer console for the topic foobar.
$ kafka-console-producer -broker-list localhost:9092 -topic foobar > foo > bar And try to send some test messages as follows: In the first one initialize a producer console for topic the foobar.Once the topic is created we can test out Kafka producer and consumer APIs: NOTE: Notice here we aren’t using -zookeeper flag as in standard documentations because Kafka versions for new MacOS do not support/ require that flag anymore. Here is an example to create a sample topic named foobar : $ kafka-topics -create -bootstrap-server localhost:9092 -replication-factor 1 -partitions 1 -topic foobar Before running any producer or consumer API it is mandatory to create a topic. A topic is a category or feed name to which records are stored and published. Start Kafka: $ kafka-server-start /opt/homebrew/etc/kafka/server.propertiesĪfter the services are successfully running, the next step is to create a kafka topic. Start Zookeeper: $ zookeeper-server-start /opt/homebrew/etc/kafka/zookeeper.properties Now to run kafka open two seperate terminals to run Zookeeper and Kafka services seperately as: Once these commands run successfully your kafka package is installed. The first steps are pretty straightforward: $ brew install java $ brew install kafka If not refer to this stackoverflow link to set it up or refer the official documentation. This article assumes that you have already setup homebrew on your MacOS M1 system.
0 kommentar(er)
