tombentley

Strimzi Quickstart

Getting up and running with a Apache Kafka cluster on Kubernetes and OKD can be very simple, when using the Strimzi project! This quick start guide walks you through a quick and easy install for your development environment, using OKD.

Start OKD

This assumes that you have the latest version of the oc binary, which you can get here.

tombentley

Kafka Cheat Sheet

Display Topic Information

$ kafka-topics.sh --describe --zookeeper localhost:2181 --topic beacon
Topic:beacon	PartitionCount:6	ReplicationFactor:1	Configs:
	Topic: beacon	Partition: 0	Leader: 1	Replicas: 1	Isr: 1
	Topic: beacon	Partition: 1	Leader: 1	Replicas: 1	Isr: 1

tombentley

TO DO

• SL = serialization library.
• SC = SerializationContext
• DC = DeserializationContext

SerializationContext.getReference()

Add method SerializationContext.getReference(Instance instance) to get the SerializableReference of an already registered instance:

tombentley

  1   b   java.lang.String::charAt (33 bytes)
  2   b   java.lang.Math::max (11 bytes)
  3   b   java.util.jar.Manifest$FastInputStream::readLine (167 bytes)
  4   b   sun.nio.cs.UTF_8$Decoder::decodeArrayLoop (553 bytes)
  5   b   java.util.Properties$LineReader::readLine (383 bytes)
  6   b   java.lang.String::hashCode (60 bytes)
  7   b   java.lang.String::indexOf (151 bytes)
  8   b   sun.nio.cs.ext.DoubleByteDecoder::decodeSingle (10 bytes)
  9   b   java.lang.String::lastIndexOf (156 bytes)
 10   b   java.lang.String::replace (142 bytes)