JorgenRingen

streamsBuilder.addStateStore(
    Stores.keyValueStoreBuilder(
        Stores.persistentKeyValueStore("storeName"),
        Serdes.StringSerde(),
        JsonSerde<OrderV2>()
    )
        .withCachingEnabled()
        .withLoggingEnabled(
            mapOf(
                RETENTION_MS_CONFIG to Duration.ofDays(30).toMillis().toString(),

JorgenRingen

package org.example.profiles

import org.apache.kafka.clients.consumer.ConsumerConfig
import org.apache.kafka.common.serialization.Serdes
import org.apache.kafka.streams.KafkaStreams
import org.apache.kafka.streams.StreamsBuilder
import org.apache.kafka.streams.StreamsConfig
import org.apache.kafka.streams.kstream.Consumed
import org.apache.kafka.streams.kstream.JoinWindows
import org.apache.kafka.streams.kstream.ValueJoiner

JorgenRingen

@KafkaListener(topics = KafkaSpringBootHelloWorldApplication.TOPIC_USERS, groupId = "${groupId}",
            topicPartitions = {
                    @TopicPartition(
                            topic = KafkaSpringBootHelloWorldApplication.TOPIC_USERS,
                            partitionOffsets = @PartitionOffset(partition = "0", initialOffset = "0"))
            })

JorgenRingen

private static final Logger LOGGER = LoggerFactory.getLogger(MethodHandles.lookup().lookupClass());

JorgenRingen

import java.lang.reflect.Method;
import java.util.logging.Logger;

import org.junit.jupiter.api.extension.AfterTestExecutionCallback;
import org.junit.jupiter.api.extension.BeforeTestExecutionCallback;
import org.junit.jupiter.api.extension.ExtensionContext;
import org.junit.jupiter.api.extension.ExtensionContext.Namespace;
import org.junit.jupiter.api.extension.ExtensionContext.Store;

public class TimingExtension implements BeforeTestExecutionCallback, AfterTestExecutionCallback {

JorgenRingen

DateTimeFormatter timeFormatter = new DateTimeFormatterBuilder()
                    .appendValue(HOUR_OF_DAY, 2)
                    .appendLiteral(':')
                    .appendValue(MINUTE_OF_HOUR, 2)
                    .optionalStart()
                    .appendLiteral(':')
                    .appendValue(SECOND_OF_MINUTE, 2)
                    .toFormatter();
            return LocalTime.now().format(timeFormatter);

JorgenRingen

    private String readContentFromFileInJarOnClasspath() {
        try {
            return StreamUtils.copyToString(new ClassPathResource("/lol.txt").getInputStream(), Charset.defaultCharset());
        } catch (IOException e) {
            throw new RuntimeException(e);
        }
    }

JorgenRingen

package no.vegvesen.kjoretoy.registrering.forhandler.web.config;

import java.util.concurrent.Executor;

import org.springframework.aop.interceptor.AsyncUncaughtExceptionHandler;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Import;
import org.springframework.core.task.SimpleAsyncTaskExecutor;
import org.springframework.scheduling.annotation.AsyncConfigurer;
import org.springframework.scheduling.annotation.EnableAsync;

JorgenRingen

            <plugin>
                <groupId>org.codehaus.mojo</groupId>
                <artifactId>flatten-maven-plugin</artifactId>
                <configuration>
                    <updatePomFile>true</updatePomFile>
                    <outputDirectory>${project.build.directory}</outputDirectory>
                    <pomElements>
                        <repositories>remove</repositories>
                    </pomElements>
                </configuration>

JorgenRingen

import javax.persistence.EntityManager;
import javax.persistence.PersistenceContext;
import javax.persistence.Table;

import java.util.List;
import java.util.stream.Collectors;

import org.springframework.beans.factory.InitializingBean;
import org.springframework.context.annotation.Profile;
import org.springframework.stereotype.Service;