ram-pi

---
services:
    kafka-connect:
        image: confluentinc/cp-server-connect:7.7.1
        hostname: kafka-connect
        container_name: kafka-connect

        healthcheck:
            test: curl -fail --silent http://kafka-connect-1:8083/connectors --output /dev/null || exit 1
            interval: 10s

ram-pi

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xmlns="http://maven.apache.org/POM/4.0.0"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.github.rampi</groupId>
    <artifactId>kafka-client-example</artifactId>
    <version>1.0-SNAPSHOT</version>

ram-pi

#!/usr/bin/env bash

# Usage: change_replication_factor.sh <bootstrap-server> <broker-list> <topic-file> <replication-factor> <min-isr> <extra-var> 
# Example: ./change_replication_factor.sh localhost:9092 1,2,3 /tmp/topic.txt 3 2 --command-config client.properties
# Example: export PATH=$PATH:/path/to/kafka/cli/bin ; ./change_replication_factor.sh localhost:9092 1,2,3 /tmp/topic.txt 3 2 --command-config client.properties
# Requires: jq, kafka-topics, kafka-reassign-partitions, kafka-configs
# Author: @ram-pi
# Version: 0.3
# Date: 2024-11-21
# Description: Change replication factor and min.insync.replicas for topics defined in a file

ram-pi

Certificate CA Validation

The easy way

To validate a certificate agains a certificate authority you just have to run

openssl verify -trusted ca_root.pem -untrusted intermediate_ca.pem certificate.pem

You'll see a 'OK' message at the end of the output

ram-pi

#!/usr/bin/env bash

# example usage: ./offsets_mover.sh localhost:9092 client.1.properties localhost:9093 client.2.properties

# get bootstrap servers from args
BOOTSTRAP_SERVER=$1

# get properties file location from args
PROPERTIES_FILE=$2

ram-pi

#!/usr/bin/env bash

# example usage: ./ips.sh localhost:9092 /etc/kafka/consumer.properties

# get bootstrap servers from args
BOOTSTRAP_SERVER=$1

# get properties file location from args
PROPERTIES_FILE=$2

ram-pi

Enable memberOf attribute on an openldap server.

Source: https://www.brianshowalter.com/blog/installing-configuring-openldap

ram-pi

#!/usr/bin/env bash

# This script is used to failover all the mirror topics from one link to another
# Usage: ./run.sh <link_id>
# Example: ./run.sh link2

# prerequisites: 
# - install jq
# - install confluent cli
# - login to confluent cloud using "confluent login" and select the environment and cluster with "confluent env use xxx" and "confluent kafka cluster use xxx

ram-pi

using System;
using Confluent.Kafka;

class Program
{
    public static void Main(string[] args)
    {
        var conf = new ProducerConfig { 
            BootstrapServers = "localhost:9092",
            SecurityProtocol = SecurityProtocol.SaslPlaintext,

ram-pi

from socket import socket, AF_INET, SOCK_DGRAM
import time
import sys


host = "localhost"
port = 10514

UDPSock = socket(AF_INET, SOCK_DGRAM)