Skip to content

Commit 045cf40

Browse files
committed
feat ( #20 ) : 임시 kafka 인터페이스
1 parent 27009f5 commit 045cf40

2 files changed

Lines changed: 28 additions & 0 deletions

File tree

Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,13 @@
1+
package hs.kr.entrydsm.user.infrastructure.kafka.producer
2+
3+
/**
4+
* 모든 테이블 삭제 이벤트를 Kafka로 발행하는 Producer 인터페이스입니다.
5+
* 관리자가 전체 데이터를 초기화할 때 다른 마이크로서비스에 알림을 전송하는 역할을 합니다.
6+
*/
7+
interface DeleteAllTableProducer {
8+
/**
9+
* 모든 테이블 삭제 이벤트를 전송합니다.
10+
* 전체 데이터 초기화 이벤트를 Kafka 토픽으로 발행합니다.
11+
*/
12+
fun send()
13+
}
Lines changed: 15 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,15 @@
1+
package hs.kr.entrydsm.user.infrastructure.kafka.producer
2+
3+
/**
4+
* 사용자 삭제 이벤트를 Kafka로 발행하는 Producer 인터페이스입니다.
5+
* 사용자 탈퇴 시 다른 마이크로서비스에 알림을 전송하는 역할을 합니다.
6+
*/
7+
interface DeleteUserProducer {
8+
/**
9+
* 사용자 삭제 이벤트를 전송합니다.
10+
* 사용자의 접수번호를 포함한 삭제 이벤트를 Kafka 토픽으로 발행합니다.
11+
*
12+
* @param receiptCode 삭제된 사용자의 접수번호
13+
*/
14+
fun send(receiptCode: Long)
15+
}

0 commit comments

Comments
 (0)