January 2018
Intermediate to advanced
336 pages
7h 56m
English
Although Clojure has Kafka wrappers (https://cwiki.apache.org/confluence/display/KAFKA/Clients#Clients-Clojure) available, this book focuses on using Apache Kafka Java APIs directly instead of a Clojure wrapper. To create a Kafka consumer, import the required Java APIs, as shown here:
(ns helping-hands.alert.channel "Initializes Helping Hands Alert Channel Consumer" (:require [cheshire.core :as jp] [clojure.string :as s] [clojure.tools.logging :as log] [helping-hands.alert.config :as conf] [postal.core :as postal]) (:import [java.util Collections Properties] [org.apache.kafka.common.serialization LongDeserializer StringDeserializer] [org.apache.kafka.clients.consumer Consumer ConsumerConfig KafkaConsumer]))
Next, define a ...
Read now
Unlock full access