신뇽이 되어보자

Trouble 1 : 카프카를 기동할 때 마주친 에러 - 메모리 초과 해결: vi kafka-server-start.sh 에 들어가서 JVM 힙 크기 조정해주었다. Trouble 2 : zookeeper실행도중 Permission 거부   ls -lia로 확인 해결:   chmod +x zoo_start.sh  Trouble 3 : producer실행시 나타난 에러 해결 : server.properties 파일에서 advertised.listeners 에 ip주소를 설정을 안해줘서 나타났던 에러였다.  Trouble 4 : 데이터베이스에 데이터를 집어넣는 과정에서 나타난 에러  (1001, 80, '교선B8051', '텍스트이해와크리에이션', '6', 532, 3, '전체', '원0207 : 월[05],..

FileAppendProducer :파일 변화를 감지하고 Kafka로 데이터를 전송하는 프로듀서 FileEventHandler객체 생성 후 FileEventSource 객체 생성 후 스레드 생성 및 실행 후스레드 반환 1. startFileMonitoring : 파일 모니터링KafkaProducer객체 생성getThread 메소드 호출하여 스레드 반환받는다.Thread fileEventSourceThread = getThread(filePath, kafkaProducer, topicName);파일 모니터링이 끝날 때까지 대기한다. 끝나면 종료. try { fileEventSourceThread.join(); // 파일 모니터링이 끝날 때까지 대기 } catch (Inter..

[Config 클래스 생성으로 카프카 소비자 구성하기] kafkaTopicConfigkafkaConsumerConfig Config파일을 만들어서 카프카 소비자 구성을 해준다.따로 파일을 만들어준 이유는 중복 코드를 방지하기 위해서이다..yml파일에 kafka기본 설정들을 저장해 놓고 호출하는 방식으로 작성하여 중요한 정보들의 노출을 막았다.//kafkaConsumerConfig@Component@Getterpublic class KafkaConsumerConfig { //카프가 소비자 구성 @Value("${kafka.topic}") private String topicName; @Value("${kafka.bootstrap-servers}") private String bo..

카프카를 기동할 때 마주친 에러 - 메모리 초과 해결: vi kafka-server-start.sh 에 들어가서 JVM 힙 크기 조정해줌 zookeeper실행도중 Permission 거부 당함  ls -lia로 확인chmod +x zoo_start.sh producer실행시 나타난 에러 해결server.properties 파일에서 advertised.listeners 에 ip주소를 설정을 안해줘서 나타났던 에러였음   (1001, 80, '교선B8051', '텍스트이해와크리에이션', '6', 532, 3, '전체', '원0207 : 월[05],화[05]', '3', 2024, 1, '강의계획서', 'FALSE') was aborted: ERROR: insert or update on table "lect..