카프카 진행상황 및 문제
ConsumerConfig.GROUP_INSTANCE_ID_CONFIG
- 컨슈머 그룹만 설정되었을 때 임의로, 컨슈머 아이디가 자동으로 생성되기 때문에 고유값을 불러오지 못해 컨슈머가 토픽에 접근할 수 없었음
- 정확히는, 서로 겹쳐 오류가 발생할 수 있다는 로그.
properties.put(ConsumerConfig.GROUP_INSTANCE_ID_CONFIG, session.getId());
- 위 코드 추가.
Consumer 생성 위치 변경
행사 시간 생성시에 Consumer도 생성해주고
Consumer 서버에서는 읽기만 해야함
nGrinder 3.5.6 설치
nGrinder 3.5.8로 하면 groovy 검증 시 오류가 발생
사용 JDK 버전: 11
nGrinder 3.5.6 Controller war 다운로드
nGrinder 3.5.6 Controller 다운로드
밑의 명령어로 Controller 서버 실행
java -Djava.io.tmpdir=/Users/hero/ngrinder -jar ngrinder-controller-3.5.6.war --port=80
nGrinder 3.5.6 agent 다운로드
- admin 누른 후 에이전트 관리 접속
- agent 다운로드 진행
/run_agent.sh 실행
중간발표 리뷰
카프카 컨슈머 서버에서 사용자에게 데이터를 전달을 할려는데 웹소켓을 써도 부담이 없을까요 다른 방법이 있을까요 ?
- 채팅에서 많이 사용하는거다.
- SSE를 쓰는게 맞음
- 정확하게는, 카프카 컨슈밍이 일어나고 난 후에 SSE를 보내야하는건가요 ?
- 컨슈머가 꼭 1회성으로 보내야하는거는 API로 호출하거나, 컨슈머가 또 다른 프로듀서로 돼서 풀어나가는 방법도 있음
행사 시간마다 카프카 토픽을 생성해서 예매에 대한 요청을 처리하려고 하는데 토픽을 계속 생성해서 사용해도 괜찮을까요 ?
- 토픽을 계속 생성하는거고 고정된 토픽에 대해서 프로듀서를 하는 것
- 토픽이 바뀌는 경우는 컨슈머가 바뀌거나 ?, 토픽 쌓는 메세지 유형이 바뀔 때
- 토픽은 보통 고정되어있다, 컨슈머는 보통 그룹에 속해있어서
- 토픽이 계속 생성이 되어야하는지? 이유가 있어야한다.
- 토픽이 관리하기가 힘들어진다
'항해99' 카테고리의 다른 글
항해99 실전 프로젝트 (20일차) (0) | 2024.02.21 |
---|---|
항해99 실전 프로젝트 (19일차) (0) | 2024.02.21 |
항해99 실전 프로젝트 (17일차) (0) | 2024.02.17 |
항해99 실전 프로젝트 (16일차) (0) | 2024.02.16 |
항해99 실전 프로젝트 (15일차) (0) | 2024.02.16 |