apache-kafka

1열

1답변

봄 통합 카프카의 ClassNotFoundException : KafkaHeaderMapper

, 나는 다음과 같은 오류를 얻고있다 봄 - 통합 - 카프카 라이브러리는 봄 부팅 응용 프로그램을 실행하는 동안 : 예외는 본문의 첫 번째 줄에서 발생합니다 Caused by: java.lang.ClassNotFoundException: org.springframework.kafka.support.KafkaHeaderMapper 다음과 같은 방법 @Serv

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답변

org.apache.kafka.common.KafkaException : io.confluent.kafka.serializers.KafkaAvroSerializer

코드 import org.apache.kafka.clients.consumer.ConsumerConfig; import org.apache.kafka.clients.consumer.ConsumerRecord; import org.apache.kafka.clients.consumer.ConsumerRecords; import org.apache.kafk

0열

1답변

dcos-vagrant에 "원격"도커 기반 서비스 배포

16GB RAM이있는 물리적 서버에 dcos-vagrant를 배포했습니다. 나는 카프카 컨테이너를 배치하고 싶지만, 내가, 내가 주로 먹 로컬 RAM에 의해 제한되지 오전 용기 (A CoreOS 서버) 이 방법은 다른 컴퓨터에서 실행되고 싶습니다 부트 스트랩으로. 어떻게해야하는지에 대한 정보를 찾지 못했습니다. 올바른 방향으로 향하는 포인터를 알려 주시면

0열

1답변

Apache Kafka 스트리밍 KTable 변경 내역

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

-1열

1답변

마지막 자동차 좌표 추적

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

0열

1답변

평균 계산을위한 스파크 스트리밍

kafka의 데이터를 null 형식의 형식으로 수신합니다. null,val1,val2,val3,val4,val5,val6,val7,...val23 null,val1,val2,val3,val4,val5,val6,val7,...val23 null,val1,val2,val3,val4,val5,val6,val7,...val23 이제 다음 코드를 사용하여 n

0열

1답변

카프카 중개인에게 직접 생산하는 웹 프론트 엔드는 실행 가능한 아이디어입니까?

나는 카프카를 배우기 시작했습니다. 그래서 소셜 미디어 웹 응용 프로그램을 만들려고합니다. 백엔드 (데이터베이스 및 기타 서비스에 대한 백엔드 통신)에 카프카 (Kafka)를 사용하는 방법은 상당히 명확합니다. 그러나 프론트 엔드가 백엔드와 어떻게 통신해야하는지 잘 모르겠습니다. 나는 건축을 다음과 같이 생각하고 있었다 : 프론트 엔드 -> 카프카 -> 백