KAFKA1 kafka transaction(exactly once semantic) kafka transaction 설명에 앞서 kafka 통신을 위한 기본적인 코드부터 설명하려 한다. 테스트 코드에서 EmbeddedKafkaBroker 를 활용해 broker 역할을 대신했다. 그리고 json 데이터를 보내기 위해 objectMapper 를 생성했다. 마지막으로 데이터 전달을 위해 Product 객체를 생성했다. public class KafkaTest { static EmbeddedKafkaBroker BROKER; static final String TOPIC_NAME = "ybs-topic"; ObjectMapper objectMapper = JsonMapper.builder().build(); static { // broker 갯수 1개, 파티션 갯수 1개 BROKER = new.. 2022. 1. 9. 이전 1 다음
