Error while fetching metadata with correlation id

Topic이 등록되지 않아서 발생했던 문제이다. Topic을 등록해서 해결했다.

ConsumerConfig에서 Topic 자동 생성 옵션 켜고 끌 수 있음

kafka template type error

Parameter 0 of constructor in com.example.kafkastudy.test2_slack.SlackReportProducerService required a bean of type 'org.springframework.kafka.core.KafkaTemplate' that could not be found.
Action:
Consider defining a bean of type 'org.springframework.kafka.core.KafkaTemplate' in your configuration.

KafkaConfig 부분에서 KafkaTemplate<String, Any> 형식으로 Template을 설정해놓고

DI를 <String, String>으로 했기 때문에 발생한 오류이다.

**KafkaConfig 부분에서 설정한 Type과 일치하도록 맞추자**.

class name이 제대로 전달되지 않아 발생한 에러

org.apache.kafka.common.config.ConfigException: 
Invalid value class org.apache.kafka.common.serialization.StringSerializer 
for configuration key.serializer: Expected a Class instance or class name.

기존 ProducerConfig.*KEY_SERIALIZER_CLASS_CONFIG to* ByteArraySerializer::*class*,

위 같은 방식으로 그냥 ::class로 해서 이름을 가져왔었는데 그게 문제가 됐다. .java를 붙여서 해결했다.

kafka pub/sub Circular Reference