카프카 Kafka 메세지 쓰기 실패 → 에러 반환 (에러 수신한 프로듀서는 메시지 쓰기 포기하고 에러 반환전에 몇번 더 재전송 시도 할 수 있음) - 프로듀서가 생성하는 레코드(ProducerRecord 객체)의 메시지 키를 직렬화하기 위한 클래스 이름을 이 속성에 설정 (key 없이 값만 전송할 때도 key.serializer 설정 필요) send() 메서드로 메시지 전송하면 Java의 Future 객체 반환 → Fut... kafka카프카kafka 스프링부트 Kafka 연습 2 - JSON 주고받기 저번에 이어서 kafka 예제를 만들어 보겠습니다. 저번 예제에서는 String형식의 메세지만 주고 받았습니다. 제가 협업프로젝트를 하면서 대부분 프론트엔드와 JSON형식으로 통신했었기에 kafka도 JSON으로 통신해야할 필요성을 느껴서 예제를 만들었습니다. JSON을 주고 받으려면 Value의 Stringserializer부분을 JSON으로 바꿔주어야합니다. 기존 방식처럼 yml에 하려고... 스프링부트채팅Springboot카프카kafkaSpringboot Confluent CLI 사용해보기 (feat. 어떨 때 사용하면 좋을까) * confluent cloud에서 rest endpoint를 제공해주는데 confluent cli와 함께 직접적으로 이 endpoint를 사용하는 방법은 찾지 못했다. 로컬에서 confluent cloud로 confluent rest kafka를 사용하기 위해서는 의 내용대로 REST Proxy 을 실행시켜 두어야 한다. confluent cloud의 endpoint url (e.g boo... 카프카컨플루언트confluent cliconfluent컨플루언트 cliconfluent
Kafka 메세지 쓰기 실패 → 에러 반환 (에러 수신한 프로듀서는 메시지 쓰기 포기하고 에러 반환전에 몇번 더 재전송 시도 할 수 있음) - 프로듀서가 생성하는 레코드(ProducerRecord 객체)의 메시지 키를 직렬화하기 위한 클래스 이름을 이 속성에 설정 (key 없이 값만 전송할 때도 key.serializer 설정 필요) send() 메서드로 메시지 전송하면 Java의 Future 객체 반환 → Fut... kafka카프카kafka 스프링부트 Kafka 연습 2 - JSON 주고받기 저번에 이어서 kafka 예제를 만들어 보겠습니다. 저번 예제에서는 String형식의 메세지만 주고 받았습니다. 제가 협업프로젝트를 하면서 대부분 프론트엔드와 JSON형식으로 통신했었기에 kafka도 JSON으로 통신해야할 필요성을 느껴서 예제를 만들었습니다. JSON을 주고 받으려면 Value의 Stringserializer부분을 JSON으로 바꿔주어야합니다. 기존 방식처럼 yml에 하려고... 스프링부트채팅Springboot카프카kafkaSpringboot Confluent CLI 사용해보기 (feat. 어떨 때 사용하면 좋을까) * confluent cloud에서 rest endpoint를 제공해주는데 confluent cli와 함께 직접적으로 이 endpoint를 사용하는 방법은 찾지 못했다. 로컬에서 confluent cloud로 confluent rest kafka를 사용하기 위해서는 의 내용대로 REST Proxy 을 실행시켜 두어야 한다. confluent cloud의 endpoint url (e.g boo... 카프카컨플루언트confluent cliconfluent컨플루언트 cliconfluent