apache-kafka-streams

2열

1답변

특정 메시지가 이미 주제에 존재하는지 여부를 확인해야하는 상황이 있습니다. 주제가 중복되지 않아도됩니다. 모든 메시지를 사용하고이를 확인하는 대신 모든 사람이이를 수행하는 모든 방법을 제안 할 수 있습니까?

1열

1답변

Kafka Streams - 저수준 프로세서 API - RocksDB TimeToLive (TTL)

저급 프로세서 API를 실험 해보았습니다. 들어오는 레코드에 대한 데이터 집계는 프로세서 API를 사용하고 집계 된 레코드를 RocksDB에 쓰고 있습니다. 그러나 rocksdb에 추가 된 레코드를 24 시간 동안 만 활성 상태로 유지하려고합니다. 24 시간이 지나면 기록을 삭제해야합니다. 이것은 ttl 설정을 변경하여 수행 할 수 있습니다. 그러나, 이것

2열

1답변

Kafka Stream 0.10.2.0 스테이트 스토어에서 값을 저장하는 동안 예외가 발생합니다.

상태 저장소가있는 로우 레벨 프로세서 API를 사용하고 있으므로 0.10.0.1까지 작동합니다.하지만 kafka 스트림을 업그레이드했지만 이후 오류가 발생합니다. 나는이 변경 로그에 대한에 기인하고 기록 맥락에서 찾고 여러 걸쳐 Processor의 같은 인스턴스를 사용할 때이 같은 java.lang.IllegalStateException: This shou

1열

1답변

Apache Kafka를 C++와 함께 사용할 수 있습니까?

저는 Apache Kafka를 처음 사용합니다. Kafka 문서 (https://kafka.apache.org/documentation.html#introduction)에는 C++에서 사용할 수 있다고 언급되어 있습니다. 하지만 어떻게해야할지 모르겠다. 내 응용 프로그램은 지속적으로 이미지 파일을 생성하므로 다른 컴퓨터로 전송해야합니다. 카프카의 스트림 A

1열

1답변

Kafka Streams - 여러 집계로 생성 된 내부 주제 수를 줄일 수 있습니까?

들어오는 메시지를 여러 값으로 그룹화하는 Kafka Streams 앱이 있습니다. 예를 들면 : 예 메시지 : { "gender": "female", "location": "canada", "age-group": "25-30" } 토폴로지 : 주제를 많이에서 table .groupBy((key, value) -> groupByGender) //

0열

1답변

Kafka Streamer : 사용자 정의 'Serdes'관련 문제

Kafka 스 트리머로 Confluent-3.2.1을 사용하고 있습니다. 내 KGroupedStream<String, MyClass1>을 KTable<Windowed<String>,MsgAggr>에 집계하려고합니다. 집계를 사용하는 동안 나는 TimeWindows.of(TimeUnit.SECONDS.toMillis(5))도 사용하고 있습니다. 나는 사용자

1열

1답변

무엇을 사용해야합니까 : Kafka Stream 또는 Kafka 소비자 API 또는 Kafka 연결

Kafka 스트림 또는 Kafka 소비자 API 또는 Kafka 연결에 대한 내게 가장 좋은 것이 무엇인지 알고 싶습니다. 주제에서 데이터를 읽은 다음 일부 처리를 수행하고 데이터베이스에 쓰기를 원합니다. 그래서 나는 소비자를 만들었지 만 Kafka 스트림 어플리케이션을 작성하고 변경을 수행하고 내 소비자 코드를 제거하고 db 코드를 작성해야하는 데이터베이

1열

2답변

카프카는 스칼라

나는 카프카 스칼라 아래 완벽하게 잘 작동 자바 내 코드가 함께 스트림을 사용하려고와 스트림 스칼라 코드가 컴파일 오류를 발생시킵니다. 유형 기대 불일치 : ForEachAction [> 문자열,> 문자열], 실제 ((어떤, 어떤), 단위) 를 찾을 수 없습니다 : 값 키 를 찾을 수 없습니다 값 값 사람에 스트림 API를 사용하는 방법을 알고 있나요 sc

1열

1답변

Apache Kafka : 프로세서가 입력마다 다중 출력을 생성합니다.

하나의 항목을 입력으로 가져와 출력으로 여러 항목을 생성해야하는 Kafka 스트림 프로세서가 있습니다. 코드를 작성하는 올바른 방법은 무엇입니까? this.context().forward(key, item)에 대한 여러 번의 호출이 올바른 방법입니까 아니면 다른 속임수입니까? 감사합니다.

0열

1답변

내 자신의 카산드라 드라이버를 사용하여 집계 결과를 작성하십시오.

내 사이트의 각 웹 페이지에 대한 페이지 뷰를 Cassandra에 쓰는 간단한 응용 프로그램을 만들려고합니다. 논리적 시간의 시작부터 누적 페이지 뷰를 5 분마다 작성하려고합니다. KTable<Windowed<String>, Long> hourlyPageViewsCounts = keyedPageViews .groupByKey() .