Pierpaolo Rametta ram-pi

Certificate CA Validation

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

Enable memberOf attribute on an openldap server.

	#!/usr/bin/env bash

	# Check if partition and offset are provided
	if [ "$#" -lt 2 ]; then
	echo "Usage: $0 <partition> <offset> [topic]"
	echo " partition: The partition number to read from"
	echo " offset: The offset to start reading from"
	echo " topic: Optional topic name (defaults to 'test')"
	exit 1
	fi

	package com.github.rampi.encryption;

	import com.azure.core.credential.TokenCredential;
	import com.azure.identity.DefaultAzureCredentialBuilder;
	import com.azure.security.keyvault.keys.KeyClient;
	import com.azure.security.keyvault.keys.KeyClientBuilder;
	import com.azure.security.keyvault.keys.cryptography.CryptographyClient;
	import com.azure.security.keyvault.keys.cryptography.CryptographyClientBuilder;
	import com.azure.security.keyvault.keys.cryptography.models.EncryptResult;
	import com.azure.security.keyvault.keys.cryptography.models.EncryptionAlgorithm;

	#!/usr/bin/env bash

	# Help function
	show_help() {
	echo "Usage: $0 [bootstrap-server] [command-config]"
	echo ""
	echo "This script checks Kafka topics for their replication factor and min.insync.replicas settings."
	echo "It will warn if the difference between these values is not 1 and suggest fixes."
	echo ""
	echo "Parameters:"

	---
	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

	<?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>

	#!/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

	#!/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

	#!/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