Skip to content

Instantly share code, notes, and snippets.

View anestoruk's full-sized avatar
🦆

Andrzej Nestoruk anestoruk

🦆
  • Poland
  • 02:54 (UTC +01:00)
View GitHub Profile
#!/bin/bash
command="tmux new-session \;"
for i in $(seq 1 $(($# - 1))); do
command="${command} split-window -h \;";
done
command="${command} select-layout tiled \;";
idx=0
package org.example;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.atomic.AtomicInteger;
public class Partitioning {
package pl.anestoruk;
import org.apache.kafka.clients.admin.AdminClient;
import org.apache.kafka.clients.admin.OffsetSpec;
import org.apache.kafka.clients.consumer.KafkaConsumer;
import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.ProducerRecord;
import org.apache.kafka.common.TopicPartition;
import org.apache.kafka.common.serialization.StringDeserializer;
import org.apache.kafka.common.serialization.StringSerializer;
@anestoruk
anestoruk / ListConversionTest.groovy
Created April 5, 2022 19:24
Camel TypeConverter issue
@SpringBootTest
@ActiveProfiles(["test"])
@DirtiesContext(classMode = DirtiesContext.ClassMode.BEFORE_EACH_TEST_METHOD)
class ListConversionTest extends Specification {
private static class SomeCoolObject {}
@TestConfiguration
static class TestRouteConfiguration {