Kafka Nots

https://softwaremill.com/kafka-visualisation/ -- java yükle apt install -y default-jdk java -version # Installing Kafka on Containers curl -fsSL https://download.docker.com/linux/ubuntu/gpg | sudo apt-key add - sudo add-apt-repository "deb [arch=amd64] https://download.docker.com/linux/ubuntu $(lsb_release -cs) stable" sudo apt update apt-get install -y docker-ce bunu ekledik // bu calismadi -- > apt-get install -y docker-ce=18.06.1~ce~3-0~ubuntu docker version usermod -a -G docker gkorkmaz curl -L "https://github.com/docker/compose/releases/download/1.24.0/docker-compose-$(uname -s)-$(uname -m)" -o /usr/local/bin/docker-compose docker-compose version // permission denied alınca access denied alınırsa bu komutu veriyoruz -- chmod +x /usr/local/bin/docker-compose git clone https://github.com/linuxacademy/content-kafka-deep-dive.git docker-compose up -d --build wget https://archive.apache.org/dist/kafka/2.6.2/kafka_2.12-2.6.2.tgz tar -zxf kafka_2.12-2.6.2.tgz -- topic olusturma bin/kafka-topics.sh --zookeeper localhost:2181 --create --topic test --partitions 3 --replication-factor 1 -- topic listeleme bin/kafka-topics.sh --zookeeper localhost:2181 --list --topic silme bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic test --------------------------------------------- --------------------------------------------- file sink --file source bin/connect-standalone.sh config/connect-standalone.properties config/connect-file-source.properties echo -e "message\nmessage2" > test.txt bin/kafka-console-consumer.sh --bootstrap-server kafka1:9092 --from-beginning --topic connect-test ----- bin/kafka-console-consumer.sh \ --bootstrap-server kafka1:9092 \ --topic __consumer_offsets \ --formatter "kafka.coordinator.group.GroupMetadataManager\$OffsetsMessageFormatter" \ --max-messages 1 ----- https://github.com/Natgho/apache-kafka-with-python # mkdir python cloud_user@fdc3182cfd1c:~$ # cd python cloud_user@fdc3182cfd1c:~$ # touch consumer.py cloud_user@fdc3182cfd1c:~$ # touch producer.py cloud_user@fdc3182cfd1c:~$ # chmod +x consumer.py cloud_user@fdc3182cfd1c:~$ # chmod +x producer.py cloud_user@fdc3182cfd1c:~$ # vi/nano editliyoruz ---------------------java ile nası yapılır kafka uygulaması https://docs.confluent.io/platform/current/tutorials/examples/clients/docs/java-springboot.html#prerequisites ------------------------------