분산 캐시 동기화 메커니즘으로 압축 된 주제로 Confluent/Apache Kafka 0.10을 사용하고 있습니다. 응용 프로그램이 시작되면 인스턴스 특정 소비자 그룹 ID가 생성됩니다. 인스턴스가 수평 확장 성을 위해 추가되고 제거됨에 따라 분명히 우리는 다시는 사용되지 않아야하는 많은 수의 그룹 ID를 얻습니다. 저는 이것이 KStreams와 KTab
아래 코드에서 stream1과 stream2는 모두 개별적으로 잘 실행되며 출력을 볼 수 있지만 조인 된 스트림은 아무 것도 기록하지 않습니다. 조인 창과 관련이 있다는 느낌이 들지만 양쪽 스트림의 데이터는 거의 정확히 같은 시간에 나타납니다. val stream = builder.stream(stringSerde, byteArraySerde, "topic
오늘 오전 롤링 윈도우 키 - 값 저장소를 구현하기 위해 약 ktables을 읽었습니다. kafka의 최신 릴리스가 이것이 가능하다는 것을 암시하는 것처럼 보일 수 있지만, '외부'응용 프로그램에서 키 - 값 데이터에 액세스하는 것에 대해 궁금합니다. 애플리케이션에서 kstreams 애플리케이션을 구현한다고 가정하면 주제에서 로그 데이터 (또는 ilk)를