onlybooks/kafka

카프카, 데이터 플랫폼의 최강자

kafka's Issues

chapter 8 source code error

LineSplit.java 가 제대로 빌드되려면 다음 코드를 추가해야 합니다.
(제 환경에서만 그런건지는 모르지만...)

저는 다음과 같이 에러가 났습니다.

[ERROR] /root/streams.examples/src/main/java/myapps/LineSplit.java:[34]
[ERROR] KStream<String, String> source = builder.stream("streams-plaintext-input");
[ERROR] ^^^^^^^
[ERROR] KStream cannot be resolved to a type
[ERROR] /root/streams.examples/src/main/java/myapps/LineSplit.java:[34]
[ERROR] KStream<String, String> source = builder.stream("streams-plaintext-input");
[ERROR] ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[ERROR] Type mismatch: cannot convert from KStream<Object,Object> to KStream<String,String>
[ERROR] 2 problems (2 errors)

다음 두 가지를 추가해서 해결했습니다.

1. KStream 추가 import
   import org.apache.kafka.streams.kstream.KStream;

2. Arrays 유틸 추가 import
   import java.util.Arrays

이상입니다. 에러나신 분들 참고하시길