Kafka

[TIL - 20230608] Webflux + Websocket + Kafka

💻현재 상황 websocket과 reactive kafka를 사용 kafkaConfig @Configuration public class KafkaConfig { @Value("${spring.kafka.bootstrap-servers}") private String bootstrapServers; @Value("${spring.kafka.consumer.group-id}") private String consumerGroupId; // group.id 값 추가 @Bean public ProducerFactory producerFactory() { Map configProps = new HashMap(); configProps.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG..