Schm1tz1

#!/usr/bin/env bash
extract_latency() {
    echo $1 | tr ',' '\n' | grep 'avg latency' | sed 's/ ms avg latency//g'
}

extract_throughput() {
  echo $1 | tr ',' '\n' | grep 'records/sec' | cut -d "(" -f2 | cut -d ")" -f1 | sed 's/ MB\/sec//g'
}

batch_size_arr=(0 10 100 1000 10000 100000 1000000)

Schm1tz1

getTempA;Vitodens_Outside_Temp
getTempWWist;Vitodens_WW_Temp
getTempWWsoll;Vitodens_WW_Temp_Set
getBrennerStatus;Vitodens_Brenner_Status
getBrennerStarts;Vitodens_Brenner_Starts
getBrennerStunden1;Vitodens_Brenner_Stunden
getTempAbgas;Vitodens_Brenner_Abgas_Temp
getTempVListM1;Vitodens_Heizung_Vorlauf_Temp
getTempRL17A;Vitodens_Heizung_Ruecklauf_Temp

Schm1tz1

blueprint:
  name: Low battery level detection & notification for all battery sensors
  description: Regularly test all sensors with 'battery' device-class for crossing
    a certain battery level threshold and if so execute an action.
  domain: automation
  input:
    threshold:
      name: Battery warning level threshold
      description: Battery sensors below threshold are assumed to be low-battery (as
        well as binary battery sensors with value 'on').

Schm1tz1

#!/usr/bin/env bash
 vclient \
     --host localhost:3002 \
     --command getTempA,getTempWWist,getTempWWsoll,getBrennerStatus,getBrennerStarts,getBrennerStunden1,getTempAbgas,    getTempVListM1,getTempRL17A \
     --json-short \
     | mosquitto_pub -h <HOST> -p <PORT> -u <USER> -P <PW> -t Viessmann -s

Schm1tz1

bootstrap.servers=localhost:9092

key.converter=io.confluent.connect.avro.AvroConverter  
value.converter=io.confluent.connect.avro.AvroConverter  
key.converter.schema.registry.url=http://localhost:8081  
value.converter.schema.registry.url=http://localhost:8081

Schm1tz1

--
-- PostgreSQL database dump
--

SET search_path TO northwind;

SET statement_timeout = 0;
SET lock_timeout = 0;
SET client_encoding = 'UTF8';
SET standard_conforming_strings = on;

Schm1tz1

---
apiVersion: platform.confluent.io/v1beta1
kind: Connector
metadata:
  name: debezium
  namespace: confluent
spec:
  class: io.debezium.connector.postgresql.PostgresConnector
  taskMax: 1
  connectClusterRef:

Schm1tz1

apiVersion: v1
kind: ConfigMap
metadata:
  name: kcat-config
  namespace: confluent
data:
  kcat.conf: |
    bootstrap.servers=kafka.confluent.svc.cluster.local:9092
    security.protocol=SASL_PLAINTEXT
    sasl.mechanisms=PLAIN

Schm1tz1

Building Kafka from the Hardware - up

• Higher Message Retention ? - Increase disk size
• Higher Message Throughput ? - Increase network capacity
• Higher Producer Performance ? - Increase Disk I/O speed
• Higher Consumer Performance ? - Increase Memory

Critical Configurations (Consumer)

• queued.min.messages
• fetch.wait.max.ms
• socket.blocking.max.ms

Schm1tz1

#!/usr/bin/env bash

mkdir ~/bin
curl -L "https://dl.k8s.io/release/$(curl -L -s https://dl.k8s.io/release/stable.txt)/bin/linux/amd64/kubectl" -o ~/bin/kubectl
chmod +x ~/bin/kubectl