Christian Posta christian-posta

Introduction to Kafka

Kafka acts as a kind of write-ahead log (WAL) that records messages to a persistent store (disk) and allows subscribers to read and apply these changes to their own stores in a system appropriate time-frame.

Terminology:

Producers send messages to brokers
Consumers read messages from brokers
Messages are sent to a topic

C++ Pointer Tutorial

Because pointers can be ugh

"Regular" variables (not pointers)

To understand a pointer, let's review "regular" variables first. If you're familiar with a programming language without pointers like JavaScript, this is what you think when you hear "variable".

When declaring a variable by identifier (or name), the variable is synonymous with its value.

tmux shortcuts & cheatsheet

start new:

tmux

start new with session name:

tmux new -s myname

	so... first make a dir $ROOT_DIR
	then make $ROOT_DIR/deployments
	copy spring-boot.jar to $ROOT_DIR/deployments
	then from $ROOT_DIR run this:
	oc import-image --from=fabric8/s2i-java:1.3 s2i-java --confirm
	oc new-build --binary=true --strategy=source --image-stream=s2i-java --name=sample-foo
	oc start-build sample-foo --from-dir=.

	#!/bin/bash
	MINIKUBE_VERSION=0.8.0
	KUBECTL_VERSION=1.3.4
	GOFABRIC8_VERSION=0.4.45
	MAVEN_VERTSION=3.3.9
	QUICKSTART_VERSION=2.2.164

	function getMinikube {
	if [[ "$OSTYPE" == "linux-gnu" ]]; then
	curl -Lo minikube https://storage.googleapis.com/minikube/releases/v$MINIKUBE_VERSION/minikube-linux-amd64

	import org.apache.kafka.clients.consumer.ConsumerRecord;
	import org.apache.kafka.clients.consumer.ConsumerRecords;
	import org.apache.kafka.clients.consumer.KafkaConsumer;
	import org.apache.kafka.clients.consumer.OffsetAndMetadata;
	import org.apache.kafka.clients.producer.ProducerConfig;
	import org.apache.kafka.common.TopicPartition;
	import org.apache.kafka.common.serialization.ByteArrayDeserializer;

	import java.util.*;

	#!/usr/bin/env bash
	#
	# gh-dl-release! It works!
	#
	# This script downloads an asset from latest or specific Github release of a
	# private repo. Feel free to extract more of the variables into command line
	# parameters.
	#
	# PREREQUISITES
	#

	package org.jboss.fuse.camel;

	import java.util.Date;

	import org.apache.camel.Exchange;
	import org.apache.camel.Processor;
	import org.apache.camel.builder.RouteBuilder;
	import org.apache.camel.main.Main;
	import org.slf4j.Logger;
	import org.slf4j.LoggerFactory;

	package org.jboss.fuse.camel;

	import java.util.ArrayList;
	import java.util.Date;
	import java.util.List;

	import org.apache.camel.Exchange;
	import org.apache.camel.ExchangePattern;
	import org.apache.camel.LoggingLevel;
	import org.apache.camel.Processor;

	/var/lib/docker/containers//-json.log {
	dateext
	daily
	rotate 365
	compress
	delaycompress
	missingok
	}