-
Notifications
You must be signed in to change notification settings - Fork 0
1140. Stream GlobalKTable Join
dkkahm edited this page Jan 14, 2022
·
1 revision
- 원천 topic에 filter 를 적용해야 한다면 중간 topic을 경유해야 한다.
- Filter를 적용하면 globalKTable은 원천 topic과 다른 update 상태를 가지게 되므로 주의해서 사용해야 한다.
builder.stream("원천 topic")
.filter()
.to("중간 topic");
var globalKTable = builder.globalKTable("중간 topic");
- KeySelector를 사용해서 topic의 Key뿐 아니라 value에서 추출된 값도 Join Key로 사용할 수 있다.
var offserStream = purchaseStream.join(userTable, (key, value) -> value.getUsername(), this::jointer, Joined.with