surysharma

@SpringBootApplication
@EnableKafkaStreams
@Log4j2
public class Main {

    public static final String APP_ID = "upper-case-demo";

    private final KafkaProperties kafkaProperties;
    private Environment env;

surysharma

@SpringBootApplication
public class KStreamSampleApplication implements CommandLineRunner {

	public static void main(String[] args) {
		SpringApplication.run(KStreamSampleApplication.class, args);
	}

	@Override
	public void run(String... args) {
		System.out.println("Started the KStream spring boot CLI...");