7c00

import java.io.IOException;
import java.nio.charset.StandardCharsets;
import java.nio.file.Files;
import java.util.Arrays;
import java.util.Iterator;
import java.util.Properties;
import org.I0Itec.zkclient.ZkClient;
import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.apache.kafka.clients.consumer.ConsumerRecords;
import org.apache.kafka.clients.consumer.KafkaConsumer;

7c00

How to set up a dev environment for hudi connector

Set up a hadoop cluster with hudi tables

Follow the doc https://hudi.apache.org/docs/docker_demo. It's sufficient to finish Step 3: Sync with Hive and then continue to next sections.

Build and launch local presto server

Follow the doc https://github.com/prestodb/presto/blob/master/README.md to build and launch your local presto server.

7c00

#!/bin/bash

set -euo pipefail

branch_messages="$(git for-each-ref --format='%(refname:short) - %(contents:subject)' refs/heads/ | gum choose --header "Select branches to delete" --no-limit)"
branches="$(echo "$branch_messages" | awk -F' - ' '{print $1}')"
[[ -z "$branches" ]] && { echo "No branches selected" && exit 0; }
for branch in $branches; do
  echo "Deleting branch: $branch"
  git branch -D "$branch"