apache-kafka-streams

0열

1답변

데이터 "A"의 스트림에 액세스하고 테이블 "B"에 대한 일부 조건을 확인하고 마지막으로 테이블 "B"의 상태를 업데이트하려고합니다. (A,B) ====> check conditions in B ====> finally update B 내가 카프카가 스트림에 동일한 로직을 구현할 수있는 방법 ? 문서에서 볼 때, 데이터 "A"를 스트리밍 할 때 Kstr

0열

1답변

Kafka 소비자 공동 주택. (Partition-Consumer allocation logic)

분산 계산의 핵심은 실행을 데이터와 함께 배치하는 것입니다. 즉, 코드에 데이터가 아닌 코드를 보낼 수 있습니다. 이것이 Hadoop, Spark 등의 핵심 디자인입니다. Kafka/Kafka Streams는 이러한 설정을 허용합니까? 그렇다면 어떻게? 계획된 것이 없다면, 아마도 하위 프로젝트로서. Kubernetes 또는 유사 사용 하시겠습니까? 주제에

0열

1답변

카프카 스트림을 사용할 때 메시지의 ID를 생성하는 방법은 무엇입니까?

합창 카프카에서 많은 글을 읽은 후에 정상적인 채팅 시스템을 구현하려고합니다. 그러나 몇 가지 구조 설계를 할 때 몇 가지 문제를 만났습니다. mysql을 데이터의 db로 사용할 때 사용자 테이블의 user_id, 메시지 테이블의 message_id와 같은 의미있는 모든 메시지에 id을 줄 수 있습니다. 모델 테이블에 ID를 부여한 후 클라이언트와 서버가

0열

1답변

Kafka Streams JoinWindow의 데이터

Kafka Streams에서 JoinWindow를 사용하여 스트림/스트림 조인을 사용하고 있습니다. 내가 이해할 수있는 것으로부터, JoinWindows는 Stores를 사용하여 구현되고 두 스트림의 데이터는 모두 RocksDB 데이터베이스에 저장됩니다. 그러나 이벤트 시간이 만료되면 (에 정의 된 보존 시간을 ()까지 전달하면 실제 데이터는 어떻게됩니까?

0열

1답변

카프카가 소비자 오프셋을 요구 오프셋으로 변경하는 방법

카프카 스트림 애플리케이션이 있습니다. 내 응용 프로그램이 이벤트를 성공적으로 처리하고 있습니다. 이벤트를 재 처리/건너 뛰기 위해 필요한 오프셋을 사용하여 Kafka 커밋 된 소비자 오프셋을 변경하는 방법. 나는 How to change start offset for topic?을 시도했다. 하지만 'Node does not exist :'오류가 발생했습

0열

1답변

종속성을 찾을 수 없습니다. 버전

에 오류를 표시합니다. pom.xml에 kafka 스트림 종속성을 포함시키고 intelij 아이디어 도구를 사용하여 스트림 종속성을 포함하려고합니다. 그러나 이러한 종속성을 찾을 수없는 오류가 표시됩니다. 그것은 kafka 스트림, slf4j API 및 slf4j log4j12 종속성에 오류를 보여줍니다 ... 그래서 아무도 문제가 도움이 될 수 있습니까?

3열

2답변

Kafka 클러스터에 Kafka 스트리밍 응용 프로그램을 배포하는 방법

카프카 스트리밍 응용 프로그램을 작성했으며이를 Kafka 클러스터에 배포하려고합니다. 그래서 jar 파일을 내장하고 명령을 사용하여 실행 java -jar KafkaProcessing-1.0-SNAPSHOT-jar-with-dependencies.jar testTopic kafka1:9092,kafka2:9092 zookeeper1:2181,zookeepe

0열

1답변

KStream 호환되지 않는 유형

문자열을 사용하여 코딩 부분으로 뭔가를 시도하고 아래 코드를 생각해 냈습니다. 코드 구문 문제를 도와주세요. 두 번째 KStream 문에서 KStreamBuilder builder = new KStreamBuilder(); KStream<String, String> textlines = builder.stream("INTOPIC"); KStream<St

0열

1답변

메시지 키는 내가 메시지 키의 유형으로 긴 사용하려고

스트림,하지만 난 확인 Exception in thread "kafka_stream_app-f236aaca-3f90-469d-9d32-20ff694806ff-StreamThread-1" org.apache.kafka.streams.errors.StreamsException: Failed to deserialize key for record. topic=te

0열

1답변

KafkaStreams applications

두 개의 kafka 스트림 응용 프로그램을 각각 다른 JVM 인스턴스에 별도로 실행하면 제대로 작동합니다. 동일한 JVM 인스턴스에서 응용 프로그램을 실행하면 두 번째 응용 프로그램이 작동하지 않습니다 (데이터를 사용하거나 생성하지 않음). 동일한 JVM 인스턴스에서 두 개의 개별 앱을 실행하는 데 제한이 있습니까? 카프카 소비자에게도 이런 일이 발생합니까