apache-kafka-streams

-1열

1답변

카프카 0.10.1.0 작업, 나는이 설정 val props = new Properties props.put(StreamsConfig.APPLICATION_ID_CONFIG, applicationId) props.put(StreamsConfig.BOOTSTRAP_SERVERS_CONFIG, broker) props.put(StreamsConfig.KE

2열

1답변

Kafka 브로커 요청 큐가 급증하여 스트림 시간 초과 예외가 발생했습니다.

4 대의 Kafka 클러스터에서 메트릭을 모니터링했습니다. 필자는 카프카에 메시지를 쓰는 입력 응용 프로그램과이 메시지를 처리하는 Kafka Streams 응용 프로그램을 사용하여 위치 정보 변수로 분할 된 새로운 카프카 항목으로 다시 작성합니다. 클러스터는 메트릭에 의심스러운 항목이보고되지 않는 불확실한 시간 (일반적으로 2 또는 3 일) 동안 아무런 문

-1열

1답변

카프카 스트림에서 null을 제거해야합니다.

--property print.key=true을 제거하면 kafka-cosole-consumer 명령이 console ...에 null을 표시하지 않기 때문에 작동하지만, 실제로 사용하고있는 디스플레이 용도 만이 아닙니다. ... 카프카에서 내 출력이을 받아 들일 수 없다 ..... 내 스트림 반응이 훨씬에만 {"timestamp":"2017-10-04T1

0열

1답변

kafka 스트림 프로세서 api 전역 상태 저장소 여러 항목

사용자 정의 프로세스가 있으므로 프로세서 api를 사용하여 kafka 스트림을 만들려고합니다. 내 프로세서가 다른 수의 파티션으로 여러 주제를 등록 할 때 문제가 발생했습니다. 글로벌 스테이트 스토어를 만들어야한다는 것을 깨달았습니다. 프로세서를 추가하는 방법과 여러 주제를 수신하는 동안 전역 상태 저장소를 추가하는 방법을 알아야합니까? 모든 코드 예제 또

0열

1답변

enable.auto.commit 값이 true로 구성되어 있지 않습니다.

Kafka 설명서에 따라 소비자 구성 enable.auto.commit의 기본값은 true입니다. 그러나 나는 거짓으로 나타납니다. 내 카프카 스트림 응용 프로그램에서이 값을 true으로 변경하여 props.put(StreamsConfig.consumerPrefix(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG), true)으로

0열

1답변

카프카 스트림을 사용하여 많은 양의 데이터 집계

카프카 스트림을 사용하여 크기가 다른 시간대를 사용하여 많은 양의 데이터를 집계하려고합니다. 캐시 크기를 2GB로 늘렸지만 1 시간 안에 창 크기를 설정하면 CPU로드가 100 %가되어 응용 프로그램이 느려지 기 시작합니다. 내 코드는 다음과 같습니다 val tradeStream = builder.stream<String, Trade>(configurati

0열

1답변

kafka 스트림의 지연 기능

kafka 스트림 코드로 뭔가를 시도하고 데이터를 분할 한 후 1ms 동안 지연 또는 thread.sleep()를 추가하려고했습니다 .... 어떻게해야합니까? 나 한테 그렇게 해? KStreamBuilder builder = new KStreamBuilder(); KStream<String, String> textlines = builder.stream(

0열

1답변

Apache Kafka 스트리밍 KTable 변경 내역

카프카 (Kafka) 주제에서 소비 된 데이터에 대해 집계를 수행하기 위해 Apache Kafka 스트리밍을 사용하고 있습니다. 그런 다음 집계가 소비되고 결과가 DB에 저장되는 다른 주제로 직렬화됩니다. 내가 생각하기에 꽤 고전적인 경우. 총 호출의 결과는 Kafka changelog "topic"에 의해 백업 된 KTable을 생성합니다. 이것은 실제로

-1열

1답변

마지막 자동차 좌표 추적

카프카 (Carafka) 주제가 있는데, 자동차 위치에 관한 데이터를 저장하고 있습니다. 나는 각 차의 단지 마지막 4 개의 좌표를 보여주는 흐름을 써야한다. 카프카 시내에서 어떻게 할 수 있습니까?

0열

1답변

Kafka -이 서버는 해당 항목의 파티션이 아닙니다.

두 개의 중개인 kafka 0.10.2.0 클러스터가 있습니다. 복제 요소는 2입니다.이 카프카에 대해 1.0.0 카프카 스트림 응용 프로그램을 실행 중입니다. 내 kafka 스트림 응용 프로그램에서 생산자 구성은 retries = 10 and retry.backoff.ms = 100 몇 분 후에 Kakfa server.log에서 다음 로그를 관찰했습니다.