나의 공부 기록

삭제할 수 없다. 3가지 대안이 있다. ⚠️ Consumer Offsets : consumer offset을 earlier로 reset한다. 데이터 손실이 일어나는 방법이니까 최후의 수단으로 사용하기 Retention Policy : 메시지를 얼마동안 보관할 것인지 토픽에 retention policy를 설정할 수 있다. ⚠️ Delete Topic : 토픽을 삭제하고 다시 생성. 영구적으로 메시지가 삭제되니까 최후의 수단으로 사용하기

Caused by: org.springframework.messaging.converter.MessageConversionException: Could not read JSON: Cannot construct instance of `x` (no Creators, like default constructor, exist): cannot deserialize from Object value (no delegate- or property-based Creator) at [Source: (byte[])"{"id":"3","username":"abc","email":"test@test.test","displayName":null,"profilePictureUrl":"rabbit.jpa","eventType":"C..

사용한 OS는 Windows 항상 Zookeeper service부터 켠다. bin\windows\zookeeper-server-start.bat config\zookeeper.properties Zookeeper service 시작 bin\windows\kafka-server-start.bat config\server.properties 새로운 터미널을 연다. Kafka broker service 시작 bin\windows\kafka-topics.bat --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test-topic test-topic 이름으로 토픽을 생성 파티션 1개, replicatio..

A default binder has been requested, but there is no binder available Caused by: java.lang.IllegalArgumentException: A default binder has been requested, but there is no binder available Kafka를 사용하는데 서버 시작하면 이 에러가 뜨고 중지된다. 😂 yml에 쓴 설정이나 다른 부분들을 봐도 문제가 없었다. 스택오버플로우를 찾아보니 의존성을 빠뜨려서 그렇다 ㅠ.ㅠ spring-cloud-stream-binder-kafka를 의존성으로 추가해주었다. 참고 👇 https://stackoverflow.com/questions/55875428/a-default-b..

분산 이벤트 저장 stream 처리 플랫폼 pub-sub모델의 Message queue Apache Software Foundation에서 Java와 Scala를 이용해 개발한 오픈 소스 시스템 내가 사용한 OS 👉 Windows11 ⚙️ Install https://www.apache.org/dyn/closer.cgi?path=/kafka/3.3.1/kafka_2.13-3.3.1.tgz Apache Downloads We suggest the following site for your download: https://dlcdn.apache.org/kafka/3.3.1/kafka_2.13-3.3.1.tgz Alternate download locations are suggested below. It is..