stuart robinson stuart-robinson

Client-side SSL

For excessively paranoid client authentication.

Organization & Common Name: Some human identifier for this server CA.

openssl genrsa -des3 -out ca.key 4096
openssl req -new -x509 -days 365 -key ca.key -out ca.crt

	(defn describe-topics [topology-builder]
	(let [topic-groups (into {} (.topicGroups topology-builder))]
	(map (fn [[k v]]
	{:task-id k
	:internal-topics (.interSourceTopics v)
	:sink-topics (.sinkTopics v)
	:source-topics (.sourceTopics v)
	:change-logs (.stateChangelogTopics v)})
	topic-groups)))

	(defn- json->map
	[bytes]
	(json/read (clojure.java.io/reader bytes)))

	(defn- calculate-partition
	;; based on algorithm from org.apache.kafka.clients.producer.internals.DefaultPartitioner
	[msg-value partition-count partition-key]
	(-> (get msg-value partition-key)
	(.getBytes)
	(Utils/murmur2)