분류 전체보기

spring boot tcp server 구현(spring integration)

spring boot에서 tcp server를 구현하는 방법중에서 spring-integration를 사용해서 tcp server를 구현해보도록 하겠습니다. spring-integration은 메시지 기반의 통합을 지원하며, TCP와 같은 다양한 프로토콜을 통한 통신을 쉽게 구현할 수 있도록 도와줍니다. 아래의 과정을 통해 Spring Boot에서 TCP 서버를 만들 수 있습니다. 1. 의존성 추가하기 spring-integration 의존성을 추가해줍니다. implementation 'org.springframework.boot:spring-boot-starter-integration' implementation 'org.springframework.integration:spring-integratio..

[mybatis] Cannot resolve reference to bean 'sqlSessionTemplate' while setting bean property 'sqlSessionTemplate' 에러

spring boot mybatis 환경에서 sql-mapper-config.xml 파일을 설정하기 전에는 오류가 발생안했는데 sql-mapper-config.xml 파일을 설정하고 서버를 실행할때 아래와 같은 오류가 발생하였습니다. Cannot resolve reference to bean 'sqlSessionTemplate' while setting bean property 'sqlSessionTemplate' 해당 에러는 주로 MyBatis와 Spring Boot를 통합할 때 발생하는 문제 중 하나입니다. 이 에러는 sqlSessionTemplate 빈을 찾을 수 없다는 것을 나타내며, 주로 설정 파일이나 프로젝트 구조와 관련이 있을 수 있습니다. 아래의 항목에 의해서 에러가 발생할 수 있습니다. ..

Kafka 외부 접속 허용

Kafka Producer, Consumer와 Kafka의 서버가 분리되어 있다면 Kafka에 외부 접속을 허용해줘야 합니다. 우선 Kafka가 설치된 서버에서 방화벽을 열어줘야 합니다. Kafka의 포트를 변경하지 않았다면 기본적으로 9092 포트를 사용하기 때문에 9092 포트를 열어줍니다. 그다음에 Kafka 서버의 설정 파일을 수정해줍니다. server.properties 파일을 열어서 아래와 같이 listeners, advertised.listeners, zookeeper.connect 정보를 추가해줍니다. broker.id=0 listeners=PLAINTEXT://:9092 advertised.listeners=PLAINTEXT://kafka가 설치된 서버 IP:9092 zookeeper.c..

Spring boot 프로젝트에서 kafka를 consume 할때 역직렬화 에러 메세지 반복 현상 해결

개요 Spring boot 프로젝트에서 kafka를 consume(구독)할때 kafka topic의 데이터를 역직렬하는 형식과 consumer 함수에서 인자로 받는 데이터 형식이 다르면 에러 메세지가 무한히 반복되게 됩니다. 이런 경우 ErrorHandlingDeserializer를 사용하면 에러 메세지가 무한히 반복되지 않습니다. ErrorHandlingDeserializer는 Apache Kafka의 Consumer에서 메시지를 역직렬화할 때 발생하는 예외를 처리하기 위한 디코더의 한 유형입니다. 이 디코더는 Kafka Consumer에게 더 나은 오류 처리 기능을 제공하여 예외를 처리하고 데이터 손실을 방지합니다. Kafka Consumer는 메시지를 읽을 때 해당 데이터를 역직렬화하여 원래 형식으..