카프카 스트림에서 스트림 DSL을 사용하여 스트림/테이블 타임 스탬프 추출기 지정

Question

카프카 스트림을 사용하여 두 가지 주제에 참여하고 싶습니다. 두 가지 주제는 서로 다른 형식의 데이터를 가지고 있으므로 다른 타임 스탬프 추출기를 사용하고 싶습니다. 이 기능 (KAFKA-4144)에 대한 병합 된 pullrequest가 있었지만 프로세서 API에 대해서는 only find it입니다.

Stream API에이 기능이 있습니까?

Answer 1

StreamsBuilder#stream(...)에는 타임 스탬프 추출기와 같은 모든 선택적 속성을 지정할 수있는 Consumed 매개 변수를 사용하는 오버로드가 있습니다.

일반적으로 https://docs.confluent.io/current/streams/javadocs/org/apache/kafka/streams/Consumed.html

, 당신은 API의 변화를 찾을 수는 업그레이드 가이드에 설명

• https://docs.confluent.io/current/streams/upgrade-guide.html#api-changes
• https://kafka.apache.org/10/documentation/streams/upgrade-guide#streams_api_changes_100