Kafka

Při asynchroním posílání zpráv je občas důležité vědět, kolik zpráv bylo přijato, kolik zpráv ještě čeká na zpracování atd. Pokud navážu na předchozí příspěvek, kde jsme si vytvořili test-topic a poslali do něj několik zpráv, můžeme k tomuto účelu použít script bin/kafka-consumer-groups.sh. Ten nám zobrazí údaje pro určitou consumer group. Konzumentská skupina (consumer group) sdružuje konzumenty (consumers).

Konzumenta, který patří do určité skupiny vytvoříte pomocí volby --group

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test-topic --group test-group --from-beginning

Pokud pošlete do tématu (topic) několik zpráv a zavoláte skript, uvidíte základní údaje. Bylo posláno pět zpráv a všechny byly zkonzumovány.

Číst dál

Apache Kafka se používá pro asynchronní posílání zpráv. V tomto příspěvku ukáži instalaci na Linux a základní práci – vytvoření téma (topic) a posílání a přijímání zpráv.

Stáhněte si Kafku a rozbalte stažený soubor (tar -xzf kafka_verze.tgz). Přesuňte se do rozbaleného adresáře. Všechny důležité skripty naleznete v adresáři bin.

Kafka používá ZooKeeper. To je služba, která udržuje informace o konfiguraci v distribuovaném prostředí. Nejdříve je tedy potřeba spustit ZooKeeper server.

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

Číst dál