Apache Kafka

Fontos fájlok és könyvtárak

• A Kafka fő telepítési könyvtára: /opt/kafka
• A Kafka broker konfigurációs fájlja: /opt/kafka/config/server.properties
• A Kafka naplókönyvtára (broker naplók, tárolt események): /opt/kafka/logs
• Kafka binárisok és CLI eszközök (kafka-topics.sh, kafka-console-producer.sh, etc.): /opt/kafka/bin
• A Kafkát kezelő Systemd service unit: /etc/systemd/system/kafka.service

Kafka Service

sudo systemctl restart kafka
sudo systemctl enable kafka
sudo systemctl status kafka

Create a Topic

/opt/kafka/bin/kafka-topics.sh --create --topic quickstart-events --bootstrap-server localhost:9092

Topik részleteinek ellenőrzése:

/opt/kafka/bin/kafka-topics.sh --describe --topic quickstart-events --bootstrap-server localhost:9092

Események küldése (üzenetek)

/opt/kafka/bin/kafka-console-producer.sh --topic quickstart-events --bootstrap-server localhost:9092

Írj egy eseményt soronként.

Press Ctrl+C to exit.

Consume Events

/opt/kafka/bin/kafka-console-consumer.sh --topic quickstart-events --from-beginning --bootstrap-server localhost:9092

Press Ctrl+C to stop reading.

Az eseményeket több kliens is többször felhasználhatja.

Logs & Troubleshooting

• Kafka logs: /opt/kafka/logs
• Systemd journal: sudo journalctl -u kafka -f
• Ensure ports 9092 (broker) and 9093 (controller) nyitva vannak.