Mehmet Cem Yücel mehmetcemyucel

## BasicStream.java
@Component
public class BasicStream {

    private static final Serde<String> STRING_SERDE = Serdes.String();
    private static final String INPUT_TOPIC = "basic-stream-input-topic";
    private static final String OUTPUT_TOPIC = "basic-stream-output-topic";

    @Autowired
    void buildPipeline(StreamsBuilder streamsBuilder) {
        KStream<String, String> messageStream = streamsBuilder.stream(INPUT_TOPIC, Consumed.with(STRING_SERDE, STRING_SERDE));

## KafkaConfig.java
@Configuration
@EnableKafka
@EnableKafkaStreams
public class KafkaConfig {

    @Value(value = "${spring.kafka.bootstrap-servers}")
    private String bootstrapAddress;


    @Bean(name = KafkaStreamsDefaultConfiguration.DEFAULT_STREAMS_CONFIG_BEAN_NAME)

## currency-eur-ny.csv

          
            HOUR/TAG:NY
            TL/EUR

            
              11:00
              18.20

            
              11:05
              18.19

            
              11:10
              18.21

## currency-eur-bi.csv

          
            HOUR/TAG:BI
            TL/EUR

            
              11:00
              18.20

            
              11:05
              18.20

            
              11:10
              18.22

## currency-usd-ny.csv

          
            HOUR/TAG:NY
            TL/USD

            
              11:00
              18.22

            
              11:05
              18.21

            
              11:10
              18.25

## currency-usd-bi.csv

          
            HOUR/TAG:BI
            TL/USD

            
              11:00
              18.23

            
              11:05
              18.22

            
              11:10
              18.24

## currency-tag.csv

          
            HOUR
            TL/USD
            TL/EUR
            TAG

            
              11:00
              18.23
              18.20
              BI

            
              11:00
              18.22
              18.20
              NY

            
              11:05
              18.22
              18.20
              BI

            
              11:05
              18.21
              18.19
              NY

            
              11:10
              18.24
              18.22
              BI

            
              11:10
              18.25
              18.21
              NY

## currency-eur.csv

          
            HOUR
            TL/EUR

            
              11:00
              18.20

            
              11:05
              18.19

            
              11:10
              18.21

## currency-usd.csv

          
            HOUR
            TL/USD

            
              11:00
              18.23

            
              11:05
              18.22

            
              11:10
              18.24

## currency.csv

          
            HOUR
            TL/USD
            TL/EUR

            
              11:00
              18.23
              18.20

            
              11:05
              18.22
              18.19

            
              11:10
              18.24
              18.21
	@Component
	public class BasicStream {

	private static final Serde<String> STRING_SERDE = Serdes.String();
	private static final String INPUT_TOPIC = "basic-stream-input-topic";
	private static final String OUTPUT_TOPIC = "basic-stream-output-topic";

	@Autowired
	void buildPipeline(StreamsBuilder streamsBuilder) {
	KStream<String, String> messageStream = streamsBuilder.stream(INPUT_TOPIC, Consumed.with(STRING_SERDE, STRING_SERDE));
	@Configuration
	@EnableKafka
	@EnableKafkaStreams
	public class KafkaConfig {

	@Value(value = "${spring.kafka.bootstrap-servers}")
	private String bootstrapAddress;


	@Bean(name = KafkaStreamsDefaultConfiguration.DEFAULT_STREAMS_CONFIG_BEAN_NAME)
HOUR	TL/USD	TL/EUR	TAG
11:00	18.23	18.20	BI
11:00	18.22	18.20	NY
11:05	18.22	18.20	BI
11:05	18.21	18.19	NY
11:10	18.24	18.22	BI
11:10	18.25	18.21	NY