วิธีการติดตั้ง Apache Kafka บน CentOS 7

Apache Kafka เป็นระบบส่งข้อความที่ปรับขนาดได้และความเร็วสูงซึ่งสามารถจัดการข้อมูลจำนวนมากได้อย่างมีประสิทธิภาพ

คุณสามารถปรับใช้ Kafka บนเซิร์ฟเวอร์เดียวหรือสร้างคลัสเตอร์ Kafka แบบกระจายเพื่อประสิทธิภาพที่ดียิ่งขึ้น ในฐานะผู้เริ่มต้นบทความนี้จะอธิบายวิธีการติดตั้ง Apache Kafka บนอินสแตนซ์เซิร์ฟเวอร์ Vultr CentOS 7 เดียว

วิชาบังคับก่อน:

ก่อนที่จะไปคุณควร:

  • ปรับใช้อินสแตนซ์เซิร์ฟเวอร์ Vultr CentOS 7 คุณอาจต้องเพิ่มหน่วยความจำที่มีทั้งนี้ขึ้นอยู่กับความต้องการของคุณ
  • ใช้ผู้ใช้ sudo เพื่อเข้าสู่ระบบจากเทอร์มินัล SSH ของคุณ

ขั้นตอนที่ 1: อัพเดทระบบ CentOS 7

ใช้คำสั่งด้านล่างเพื่ออัปเดตระบบของคุณเป็นสถานะล่าสุด:

sudo yum update -y && sudo reboot

หลังจากรีบูตเสร็จสิ้นให้ใช้ผู้ใช้ sudo คนเดียวกันเพื่อเข้าสู่ระบบอีกครั้ง

ขั้นตอนที่ 2: ติดตั้ง OpenJDK Runtime

คุณต้องตั้งค่าเครื่องเสมือน Java บนระบบของคุณก่อนจึงจะสามารถเรียกใช้ Apache Kafka ได้อย่างถูกต้อง ที่นี่คุณสามารถติดตั้ง OpenJDK Runtime Environment 1.8.0 โดยใช้ YUM:

sudo yum install java-1.8.0-openjdk.x86_64

ตรวจสอบการติดตั้งของคุณด้วย:

java -version

ผลลัพธ์ควรมีลักษณะดังนี้:

openjdk version "1.8.0_91"
OpenJDK Runtime Environment (build 1.8.0_91-b14)
OpenJDK 64-Bit Server VM (build 25.91-b14, mixed mode)

คุณต้องตั้งค่าตัวแปรสภาพแวดล้อม "JAVA_HOME" และ "JRE_HOME":

sudo vi /etc/profile

ต่อท้ายบรรทัดต่อไปนี้กับเนื้อหาต้นฉบับของไฟล์:

export JAVA_HOME=/usr/lib/jvm/jre-1.8.0-openjdk
export JRE_HOME=/usr/lib/jvm/jre

บันทึกและออก:

:wq

โหลดโปรไฟล์ซ้ำเพื่อให้การเปลี่ยนแปลงมีผล:

source /etc/profile

ขั้นตอนที่ 3: ดาวน์โหลด Apache Kafka

ดาวน์โหลด Apache Kafka เวอร์ชั่นเสถียรล่าสุดได้จากเว็บไซต์ทางการ 0.9.0.1ในขณะที่เขียนก็

cd ~
wget http://www-us.apache.org/dist/kafka/0.9.0.1/kafka_2.11-0.9.0.1.tgz

แตกไฟล์ที่เก็บถาวรไปยังตำแหน่งที่ต้องการเช่น/opt:

tar -xvf kafka_2.11-0.9.0.1.tgz
sudo mv kafka_2.11-0.9.0.1 /opt

ขั้นตอนที่ 4: เริ่มและทดสอบ Apache Kafka

ณ จุดนี้ Apache Kafka มีอยู่ในระบบของคุณ มาทดสอบขับกันเถอะ

4.1: เข้าไปในไดเรกทอรี Kafka

cd /opt/kafka_2.11-0.9.0.1

4.2: เริ่มเซิร์ฟเวอร์ Zookeeper

bin/zookeeper-server-start.sh -daemon config/zookeeper.properties

4.3: แก้ไขการกำหนดค่าเซิร์ฟเวอร์ Kafka ของคุณ

 vi bin/kafka-server-start.sh

ปรับการใช้หน่วยความจำตามพารามิเตอร์ระบบเฉพาะของคุณ ตัวอย่างเช่นหากคุณใช้เซิร์ฟเวอร์ Vultr กับหน่วยความจำ 768MB ในสภาพแวดล้อมการทดสอบคุณจะต้องค้นหาบรรทัดต่อไปนี้:

export KAFKA_HEAP_OPTS="-Xmx1G -Xms1G"

แทนที่ด้วย:

export KAFKA_HEAP_OPTS="-Xmx256M -Xms128M"

บันทึกการเลิก:

:wq

4.4: เริ่มเซิร์ฟเวอร์ Kafka

bin/kafka-server-start.sh config/server.properties

หากทุกอย่างประสบความสำเร็จคุณจะเห็นข้อความหลายข้อความเกี่ยวกับสถานะของเซิร์ฟเวอร์ Kafka และข้อความล่าสุดจะอ่าน:

INFO [Kafka Server 0], started (kafka.server.KafkaServer)

ซึ่งหมายความว่าคุณได้เริ่มต้นเซิร์ฟเวอร์ Kafka แล้ว

4.5: สร้างหัวข้อ "ทดสอบ" ในการเชื่อมต่อ SSH ใหม่

เปิดการเชื่อมต่อ SSH ใหม่ใช้คำสั่งต่อไปนี้เพื่อสร้างหัวข้อ "ทดสอบ":

cd /opt/kafka_2.11-0.9.0.1
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

คุณสามารถดูหัวข้อของคุณด้วยคำสั่งต่อไปนี้:

bin/kafka-topics.sh --list --zookeeper localhost:2181

ในกรณีของเราเอาต์พุตจะอ่าน:

test

4.6: สร้างข้อความโดยใช้หัวข้อ "ทดสอบ"

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

ด้วยการใช้คำสั่งด้านบนคุณสามารถป้อนข้อความจำนวนเท่าใดก็ได้ตามที่คุณต้องการเช่น:

Welcome aboard!
Bonjour!

หากคุณได้รับข้อผิดพลาดคล้ายกับ"WARN Error while fetching metadata with correlation id"ในขณะที่ป้อนข้อความคุณจะต้องอัปเดตserver.propertiesไฟล์ด้วยข้อมูลต่อไปนี้:

port = 9092
advertised.host.name = localhost 

4.7: แสดงข้อความ

เปิดการเชื่อมต่อ SSH ที่สามแล้วเรียกใช้คำสั่งต่อไปนี้:

cd /opt/kafka_2.11-0.9.0.1
bin/kafka-console-consumer.sh --zookeeper localhost:9092 --topic test --from-beginning

Ta-da! ข้อความที่คุณสร้างไว้ก่อนหน้านี้จะแสดงในการเชื่อมต่อ SSH ที่สาม แน่นอนถ้าคุณป้อนข้อความเพิ่มเติมจากการเชื่อมต่อ SSH ที่สองตอนนี้คุณจะเห็นพวกเขาทันทีในการเชื่อมต่อ SSH ที่สาม

สุดท้ายคุณสามารถกด Ctrl + C ในแต่ละการเชื่อมต่อ SSH เพื่อหยุดสคริปต์เหล่านี้

แค่นั้นแหละ. คุณสามารถเรียนรู้เพิ่มเติมเกี่ยวกับ Apache Kafka ได้จากเว็บไซต์ทางการ มีความสุข!



Leave a Comment

วิธีการติดตั้ง Directus 6.4 CMS บน CentOS 7 LAMP VPS

วิธีการติดตั้ง Directus 6.4 CMS บน CentOS 7 LAMP VPS

เรียนรู้วิธีการติดตั้ง Directus 6.4 CMS บน CentOS 7; ระบบการจัดการเนื้อหา Headless ที่มีความยืดหยุ่นสูงและปลอดภัย

การติดตั้ง Pagekit CMS บน CentOS 7

การติดตั้ง Pagekit CMS บน CentOS 7

ใช้ระบบที่แตกต่างกันอย่างไร Pagekit เป็น CMS โอเพนซอร์สที่เขียนด้วย PHP ซอร์สโค้ดของ Pagekit นั้นโฮสต์บน GitHub คำแนะนำนี้จะแสดงให้คุณเห็นว่า

วิธีการติดตั้ง TestLink บน CentOS 7

วิธีการติดตั้ง TestLink บน CentOS 7

TestLink เป็นระบบดำเนินการจัดการทดสอบบนเว็บโอเพ่นซอร์ส ช่วยให้ทีมงานประกันคุณภาพสามารถสร้างและจัดการกรณีทดสอบได้เช่นกัน

วิธีการที่ปลอดภัย vsFTPd ด้วย SSL / TLS

วิธีการที่ปลอดภัย vsFTPd ด้วย SSL / TLS

FTP ที่ปลอดภัยมากหรือเพียงแค่ vsFTPd เป็นซอฟต์แวร์น้ำหนักเบาที่มีความสามารถในการปรับแต่ง ในบทช่วยสอนนี้เราจะรักษาความปลอดภัยของข้อความ

วิธีการติดตั้ง GCC บน CentOS 6

วิธีการติดตั้ง GCC บน CentOS 6

CentOS ติดตามการพัฒนา Red Hat Enterprise Linux (RHEL) RHEL พยายามที่จะเป็นแพลตฟอร์มเซิร์ฟเวอร์ที่มั่นคงซึ่งหมายความว่าจะไม่รีบเร่งในการรวม

ตั้งค่าบัญชีผู้ใช้ SFTP เท่านั้นบน CentOS 7

ตั้งค่าบัญชีผู้ใช้ SFTP เท่านั้นบน CentOS 7

ในบางโอกาสผู้ดูแลระบบอาจต้องสร้างบัญชีผู้ใช้และ จำกัด การเข้าถึงเพื่อจัดการไฟล์ของตัวเองผ่าน sFTP เท่านั้น

วิธีการติดตั้ง Moodle บน CentOS 7

วิธีการติดตั้ง Moodle บน CentOS 7

ใช้ระบบที่แตกต่างกันอย่างไร Moodle เป็นแพลตฟอร์มการเรียนรู้โอเพนซอร์ซหรือระบบจัดการหลักสูตร (CMS) - ชุดซอฟต์แวร์โอเพ่นซอร์สฟรีที่ออกแบบมาเพื่อช่วย

ติดตั้ง NGINX พร้อม ModSecurity บน CentOS 6

ติดตั้ง NGINX พร้อม ModSecurity บน CentOS 6

ในบทความนี้ฉันจะอธิบายวิธีสร้าง LEMP สแต็คที่ได้รับการป้องกันโดย ModSecurity ModSecurity เป็นไฟร์วอลล์เว็บแอพพลิเคชันแบบโอเพนซอร์สที่มีประโยชน์

วิธีการติดตั้ง Apache, MySQL และ PHP บน CentOS 6

วิธีการติดตั้ง Apache, MySQL และ PHP บน CentOS 6

Introduction LAMP เป็นคำย่อที่ย่อมาจาก Linux, Apache, MySQL และ PHP ซอฟต์แวร์นี้เป็นโซลูชันโอเพ่นซอร์สที่ได้รับความนิยมสูงสุดสำหรับการติดตั้ง o

การปรับเปลี่ยน Icinga2 ให้ใช้โมเดลต้นแบบ / ไคลเอ็นต์บน CentOS 6 หรือ CentOS 7

การปรับเปลี่ยน Icinga2 ให้ใช้โมเดลต้นแบบ / ไคลเอ็นต์บน CentOS 6 หรือ CentOS 7

Icinga2 เป็นระบบการตรวจสอบที่มีประสิทธิภาพและเมื่อใช้ในโมเดลลูกค้าหลักจะสามารถแทนที่ความต้องการการตรวจสอบที่อิง NRPE ปรมาจารย์

การติดตั้ง Netdata บน CentOS 7

การติดตั้ง Netdata บน CentOS 7

ใช้ระบบที่แตกต่างกันอย่างไร Netdata เป็นดาวรุ่งพุ่งแรงในด้านการติดตามการวัดในระบบแบบเรียลไทม์ เมื่อเปรียบเทียบกับเครื่องมือชนิดเดียวกัน Netdata:

วิธีการติดตั้งและกำหนดค่า Buildbot บน CentOS 7

วิธีการติดตั้งและกำหนดค่า Buildbot บน CentOS 7

Buildbot เป็นโอเพ่นซอร์สเครื่องมือที่ใช้การรวมอย่างต่อเนื่องของ Python สำหรับการสร้างซอฟต์แวร์การทดสอบและการปรับใช้โดยอัตโนมัติ Buildbot ประกอบด้วยหนึ่งหรือหมอ

ติดตั้งเซิร์ฟเวอร์มัลติเพลเยอร์ SA-MP San Andreas บน CentOS 6

ติดตั้งเซิร์ฟเวอร์มัลติเพลเยอร์ SA-MP San Andreas บน CentOS 6

ยินดีต้อนรับสู่การกวดวิชา Vultr อื่น ที่นี่คุณจะได้เรียนรู้วิธีการติดตั้งและเรียกใช้เซิร์ฟเวอร์ SAMP คู่มือนี้เขียนขึ้นสำหรับ CentOS 6 ข้อกำหนดเบื้องต้นคุณจะต้อง

ติดตั้ง dotProject บน CentOS 7

ติดตั้ง dotProject บน CentOS 7

แอปพลิเคชั่น dotProject เป็นเครื่องมือการจัดการโครงการแบบโอเพ่นซอร์สบนเว็บ สำหรับตอนนี้มันวางจำหน่ายภายใต้ GPL ดังนั้นคุณสามารถปรับใช้และใช้งานได้บนบริการของคุณ

ติดตั้ง TaskServer (taskd) บน CentOS 7

ติดตั้ง TaskServer (taskd) บน CentOS 7

ใช้ระบบที่แตกต่างกันอย่างไร TaskWarrior เป็นเครื่องมือจัดการเวลาแบบโอเพ่นซอร์สที่เป็นการปรับปรุงแอพพลิเคชั่น Todo.txt และโคลนของมัน เนื่องมาจาก

วิธีการติดตั้ง Selfoss RSS Reader บน CentOS 7 LAMP VPS

วิธีการติดตั้ง Selfoss RSS Reader บน CentOS 7 LAMP VPS

ใช้ระบบที่แตกต่างกันอย่างไร Selfoss RSS Reader เป็นฟรีและเปิดตัวเองบนเว็บโฮสต์อเนกประสงค์, สตรีมสด, ตอบโต้กับผู้ใช้ได้, ฟีดข่าว (RSS / Atom) reade

วิธีการติดตั้ง Kanboard บน CentOS 7

วิธีการติดตั้ง Kanboard บน CentOS 7

ใช้ระบบที่แตกต่างกันอย่างไร Kanboard เป็นซอฟต์แวร์ซอฟต์แวร์การจัดการโครงการโอเพ่นซอร์สฟรีที่ออกแบบมาเพื่ออำนวยความสะดวกและมองเห็นภาพการทำงานเป็นทีม

การตั้งค่าเซิร์ฟเวอร์ Half Life 2 บน CentOS 6

การตั้งค่าเซิร์ฟเวอร์ Half Life 2 บน CentOS 6

บทช่วยสอนนี้จะกล่าวถึงกระบวนการติดตั้งเซิร์ฟเวอร์เกม Half Life 2 บนระบบ CentOS 6 ขั้นตอนที่ 1: การติดตั้งข้อกำหนดเบื้องต้นเพื่อตั้งค่า ou

ไดรฟ์ที่แชร์ความพร้อมใช้งานสูงใช้ Vultr Block Storage และ GlusterFS

ไดรฟ์ที่แชร์ความพร้อมใช้งานสูงใช้ Vultr Block Storage และ GlusterFS

GlusterFS เป็นระบบไฟล์ที่เชื่อมต่อกับเครือข่ายซึ่งช่วยให้คุณแบ่งปันไดรฟ์สองตัวในอุปกรณ์หลายตัวบนเครือข่ายได้อย่างมีประสิทธิภาพ ระบบไฟล์นี้คือ

วิธีโยกย้ายกล่องจดหมายอย่างง่ายดายด้วย Imapsync บน CentOS 7

วิธีโยกย้ายกล่องจดหมายอย่างง่ายดายด้วย Imapsync บน CentOS 7

ใช้ระบบที่แตกต่างกันอย่างไร ในขณะที่การโยกย้ายเว็บไซต์มักจะไม่มีปัญหาบางครั้งก็ยากที่จะโยกย้ายกล่องอีเมล นี่คือ CAS โดยเฉพาะอย่างยิ่ง

วิธีการติดตั้ง Directus 6.4 CMS บน CentOS 7 LAMP VPS

วิธีการติดตั้ง Directus 6.4 CMS บน CentOS 7 LAMP VPS

เรียนรู้วิธีการติดตั้ง Directus 6.4 CMS บน CentOS 7; ระบบการจัดการเนื้อหา Headless ที่มีความยืดหยุ่นสูงและปลอดภัย

ตั้งค่า Nginx บน Ubuntu เพื่อสตรีมวิดีโอสด HLS

ตั้งค่า Nginx บน Ubuntu เพื่อสตรีมวิดีโอสด HLS

เรียนรู้วิธีการตั้งค่า Nginx บน Ubuntu สำหรับการสตรีมวิดีโอสด HLS ด้วยคำแนะนำที่ชัดเจนและเป็นประโยชน์

การสำรองข้อมูลยอดนิยมด้วย Percona XtraBackup บนแอพ WordPress แบบคลิกเดียว

การสำรองข้อมูลยอดนิยมด้วย Percona XtraBackup บนแอพ WordPress แบบคลิกเดียว

เรียนรู้การใช้ Percona XtraBackup สำหรับการสำรองข้อมูลด้วยวิธีที่เป็นระบบและง่ายดายบน WordPress ออนไลน์ของคุณ

ReactOS: นี่คืออนาคตของ Windows หรือไม่?

ReactOS: นี่คืออนาคตของ Windows หรือไม่?

ReactOS ซึ่งเป็นโอเพ่นซอร์สและระบบปฏิบัติการฟรีพร้อมเวอร์ชันล่าสุดแล้ว สามารถตอบสนองความต้องการของผู้ใช้ Windows ยุคใหม่และล้ม Microsoft ได้หรือไม่? มาหาข้อมูลเพิ่มเติมเกี่ยวกับรูปแบบเก่านี้ แต่เป็นประสบการณ์ OS ที่ใหม่กว่ากัน

AI สามารถต่อสู้กับการโจมตีของแรนซัมแวร์ที่เพิ่มขึ้นได้หรือไม่

AI สามารถต่อสู้กับการโจมตีของแรนซัมแวร์ที่เพิ่มขึ้นได้หรือไม่

การโจมตีของ Ransomware กำลังเพิ่มขึ้น แต่ AI สามารถช่วยจัดการกับไวรัสคอมพิวเตอร์ตัวล่าสุดได้หรือไม่? AI คือคำตอบ? อ่านที่นี่รู้ว่า AI boone หรือ bane

เชื่อมต่อผ่าน WhatsApp Desktop App 24*7

เชื่อมต่อผ่าน WhatsApp Desktop App 24*7

ในที่สุด Whatsapp ก็เปิดตัวแอพเดสก์ท็อปสำหรับผู้ใช้ Mac และ Windows ตอนนี้คุณสามารถเข้าถึง Whatsapp จาก Windows หรือ Mac ได้อย่างง่ายดาย ใช้ได้กับ Windows 8+ และ Mac OS 10.9+

AI จะนำกระบวนการอัตโนมัติไปสู่อีกระดับได้อย่างไร

AI จะนำกระบวนการอัตโนมัติไปสู่อีกระดับได้อย่างไร

อ่านข้อมูลนี้เพื่อทราบว่าปัญญาประดิษฐ์กำลังได้รับความนิยมในหมู่บริษัทขนาดเล็กอย่างไร และเพิ่มโอกาสในการทำให้พวกเขาเติบโตและทำให้คู่แข่งได้เปรียบ

การอัปเดตเสริม macOS Catalina 10.15.4 ทำให้เกิดปัญหามากกว่าการแก้ปัญหา

การอัปเดตเสริม macOS Catalina 10.15.4 ทำให้เกิดปัญหามากกว่าการแก้ปัญหา

เมื่อเร็ว ๆ นี้ Apple เปิดตัว macOS Catalina 10.15.4 การอัปเดตเสริมเพื่อแก้ไขปัญหา แต่ดูเหมือนว่าการอัปเดตทำให้เกิดปัญหามากขึ้นที่นำไปสู่การสร้างเครื่อง Mac อ่านบทความนี้เพื่อเรียนรู้เพิ่มเติม

13 เครื่องมือดึงข้อมูลเชิงพาณิชย์ของ Big Data

13 เครื่องมือดึงข้อมูลเชิงพาณิชย์ของ Big Data

13 เครื่องมือดึงข้อมูลเชิงพาณิชย์ของ Big Data

ระบบไฟล์บันทึกคืออะไรและทำงานอย่างไร

ระบบไฟล์บันทึกคืออะไรและทำงานอย่างไร

คอมพิวเตอร์ของเราจัดเก็บข้อมูลทั้งหมดในลักษณะที่เรียกว่าระบบไฟล์บันทึก เป็นวิธีการที่มีประสิทธิภาพที่ช่วยให้คอมพิวเตอร์สามารถค้นหาและแสดงไฟล์ได้ทันทีที่คุณกดค้นหาhttps://wethegeek.com/?p=94116&preview=true