apache-kafka-streams

0열

1답변

나는 카프카의 토폴로지 다음과 같은 정의 Operation 1 : input_stream ----> filter ----> window_processing ----> write_to_topic Operation 2 : input_stream ----> write_to_topic 나는 두 작업은 동일한 스레드 (내가 스레딩에 대한 StreamsConfi

1열

2답변

kafka에서 읽기 및 kafka로 kafka로 읽는 성능을 향상시키는 방법 Stream Application

카프카 스트림 응용 프로그램에 1.0.0 카프카 스트림 API가 있습니다. 단일 브로커 0.10.2.0 kafka 및 단일 파티션의 단일 주제가 있습니다. 구성 가능한 모든 매개 변수는 제작자 request.timeout.ms를 제외하고 동일합니다. Kafka Streams program is throwing exceptions when producing

2열

1답변

카프카 스트림 앱을 자동으로 배포합니다.

카프카 및 카프카 스트리밍 애플리케이션으로 시작합니다. 한 주제에서 소비하고,이 메시지를 처리 한 다음 다른 주제로 보내주는 Kafka Stream App을 작성했습니다. 본인이 아는 , 나는 코딩이 카프카 스트림 응용 프로그램을 실행하는 데 발견하는 유일한 방법은 다음과 같습니다 IDE에서 Java 실행 클래스입니다. *.jar 파일을 생성하고 프롬프

-1열

1답변

입력 레코드 타임 스탬프 및 출력 레코드 타임 스탬프는 원본 및 싱크 항목에서 동일합니까?

프로세서 API를 사용하여 카프카 스트리밍 응용 프로그램을 만듭니다. 내가 들어오는 모든 메시지 에 타임 스탬프를 첨부 할 항목을 만드는 방법은 다음과 이다 kafka-topics.sh --create --zookeeper 로컬 호스트 : 2181 --replication 요인 1 --partitions 1 - -topic topicName --config

2열

2답변

KStream을 콘솔로 인쇄하는 방법은 무엇입니까?

카프카 주제를 만들고 메시지를 푸시했습니다. 그래서 bin/kafka-console-consumer --bootstrap-server abc.xyz.com:9092 --topic myTopic --from-beginning --property print.key=true --property key.separator="-" 인쇄 명령 줄에서 key1-cus

0열

1답변

카프카 스트림은 GenericAvroSerde

에 알 수없는 마법 바이트는 카프카 스트림과 브로 데이터를 스트리밍 할 때,이 오류를 건너 왔어요 거기에 언급 된 해결책 중 어느 것도 문제를 해결하지 못했습니다. 바라건대 여기서 해결책을 찾을 수 있습니다. 다음과 같이 내 설정은 같습니다 StreamsConfig.KEY_SERDE_CLASS_CONFIG, Serdes.String.getClass.getN

0열

1답변

주어진 창에 대한 스트림을 통한 통계 계산

나는 자주 틱하는 KStream (초)을 생각하고 24 시간 동안 다양한 통계를 계산하려고합니다. 예를 들어, 24 시간 변경, 특정 시점과 그 시점 이전의 24 시간 간의 가격 차이. 내 원하는 입력 내 출력은 다음과 같습니다 t1 -> t1c1 t2 -> t1c2 t3 -> t1c3 t1 입력 시세입니다 및 t1c1은 이전의 24 시간 창에 대해

1열

1답변

카프카 스트림 재조정 : REBALANCING에서 ERROR 로의 상태 천이

단일 파티션과 3 개의 애플리케이션으로 네 개의 주제가 있습니다. 1 인스턴스 항목 1, partition0을, topic4, partition0을 2 인스턴스 항목 2, partition0을 3 인스턴스 topic3 : 나는 다음과 같이 3 작업을 생성 할 사용자 정의 PartitionGrouper를 작성하여 확장 성을 달성하기 위해 노력 , part

0열

1답변

Kafka Streams : 동일한 'application.id'를 사용하여 여러 주제에서 사용하십시오.

여러 개의 다른 주제를들을 필요가있는 애플리케이션이 있습니다. 각 주제에는 메시지 처리 방법에 대한 별도의 논리가 있습니다. 각 KafkaStreams 인스턴스에 대해 동일한 카프카 속성을 사용하려고 생각했지만 아래 오류가 발생합니다. 오류 java.lang.IllegalArgumentException: Assigned partition my-topic-1

2열

1답변

KSQL 테이블의 데이터 읽기

어쩌면 이것은 초보자 용 질문 일 수도 있지만 KSQL에서 생성 된 데이터를 읽는 데 권장되는 방법은 무엇입니까? 일부 스트림 처리를 수행하고 데이터를 KSQL 테이블에 기록한다고 가정 해 보겠습니다. 이제 스프링 애플리케이션을 통해이 데이터에 액세스하려고합니다 (예 : 웹 소켓을 통해 일부 실시간 데이터 팬 아웃). 내 첫 번째 추측은 Spring Kaf