apache-kafka-connect

1열

3답변

내가 elasticsearch에 elasticsearch 얻기 다음과 같은 오류를 연결 카프카 사용하여 탄성 검색에 아파치 카프카로부터 데이터를 전송하려고 elaticsearch하기 : [2017-12-21T11:00:54,979][DEBUG][o.e.a.b.TransportShardBulkAction] [pageviews7][0] failed to ex

0열

1답변

카프카 (Kafka) 두 개의 다른 체크 포인트가있는 한 명의 소비자

카프카 (Kafka)의 특정 주제에서 데이터를 소비하는 카프카 소비자 프로젝트가 있습니다. 레코드의 90 %는 처리 되 자마자 처리되지만 일부 레코드 (10 %)를 처리하는 지연이 있습니다. 이러한 기록을 지연시켜야 기록을 커밋 할 수 없으므로 Kafka가 새 노드에 파티션을 재 할당 할 수 있습니다. 이를 방지하기 위해 동일한 주제를 두 번 읽고 두 번째

2열

1답변

KSQL 테이블의 데이터 읽기

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

0열

1답변

kafka mongodb 싱크 커넥터가 시작되지 않음

나는 confluent_3.3.0을 설치했으며 zookeper, schema-registry 및 kafka 브로커를 시작했습니다. 그리고 싱크 커넥터를 실행 링크 https://github.com/RADAR-CNS/MongoDb-Sink-Connector 아래에서 다운로드 MongoDB를 커넥터 ./bin/connect-standalone etc/kafka

1열

2답변

kafka를 여러 노드에서 분산 모드로 연결

kafka 커넥터를 탄력적으로 테스트 중이므로 실행중인 작업자를 죽여서 커넥터 인스턴스를 종료하고 싶습니다. 가장 쉬운 방법은 분산 모드가 둘 이상의 노드에서 실행되도록 강제하는 것입니다. 그런 다음 해당 노드에서 작업자 프로세스를 종료하면됩니다. 카프카가 시작한 노드 이상에서 카프카를 어떻게 연결시킬 수 있습니까? 이것은 worker config에 정의

0열

1답변

org.springframework.kafka.listener.ListenerExecutionFailedException : 리스너 메소드가 java.lang.NullPointerException을 던졌습니다.

리스너 메소드의 내 고객 클래스 InventoryEventReceiver에서 아래 오류가 발생합니다. NullPointerException이 표시되는 이유를 모르십니까? 나는 단지 두 개의 InventoryEvent 개체를 게시하고 있습니다. 빠른 도움말을 보내 주시면 감사하겠습니다. 리스너 방법 public class InventoryEventReceiv

0열

1답변

Kafka JDBC 커넥터에 연결

io.confluent.connect.jdbc.JdbcSourceConnector를 쿼리를 사용하여 대량 모드로 사용하려고합니다. query = select name, cast(ID as NUMBER(20,2)),status from table_name 가능합니까? 가능한 경우 누락 되었습니까? 받고 있어요 exception (org.apache.kaf

0열

1답변

필수 인수가 없습니다. "[authorizer-properties]"apache kafka 간단한 제작자 API 오류

kafka 제작자 코드를 일식에 쓰는 동안 아래에 오류 설명이 표시됩니다. 여기 간단한 제작자 코드를 작성하고 kafka 콘솔에 메시지를 표시하고 싶습니다. 소비자 내가 사육사와 카프카 서버를 시작하고 주제를 완벽하게 만들었습니다. import java.util.Properties; import kafka.javaapi.producer.Producer;

-2열

1답변

kafka 메시징 시스템을 사용하는 oracle 데이터베이스에 대한 쿼리

데이터웨어 하우스 인 oracle 데이터베이스가 있고 시스템에서 kafka 메시징 시스템을 사용하고 있습니다. 재난 복구 솔루션에서 kafka를 사용하여 oracle 데이터베이스에서 쿼리를 수행 한 다음 질의 된 메시지를 H2 데이터베이스로 복사합니다. 당신은 kafka를 사용하여 oracle 데이터베이스에서 쿼리하는 솔루션을 가지고 있습니까? 나는 "합류

0열

2답변

Apache Kafka 주제 및 스트림 데이터를 하이브 테이블에 등록하는 방법

Apache Kafka 주제를 구독하고 하이브 테이블에 주제 데이터를 스트리밍하는 방법은 무엇입니까? 카프카 주제가 실시간으로 업데이트됩니다.