confluent

0열

2답변

Confluent Schema Registry Offset Management

우리는 Confluent Schema Registry를 Avro Schema Repo로 사용합니다. 내가 관찰 한 것은 사육사에게 소비자 오프셋 관리가 없다는 것입니다. 스키마 레지스트리가 설계된 방식 때문입니다. 사육사의 오프셋을 저장하지 않고 Kafka를 사용하거나 카프카의 압축 로그/토픽의 경우 표준 디자인 패턴입니까?

0열

1답변

JDBC 싱크 커넥터 - kafka-connect를 사용하여 여러 테이블 항목에서 여러 테이블로 업 그레 이터

JDBC 싱크 커넥터를 사용하여 2 개의 카프카 항목을 읽고이를 수동으로 만든 2 개의 Oracle 테이블로 업 샘플하려고합니다. 각 테이블에는 upsert 모드에서 사용하려는 1 개의 기본 키가 있습니다. 커넥터는 1 주제에 대해서만 사용하고 pk.fields에서는 1 필드 만 사용하면 잘 작동하지만 각 테이블에서 하나씩 pk.fields에 여러 열을 입

4열

1답변

합류 3.3 업그레이드 후 Kafka-cassandra 커넥터가 실패 함

3.3.0으로 업그레이드 한 후 Cassandra 커넥터가 실패합니다. 카산드라 드라이버 버전은 3.3입니다. 스택은 아래에 나와 있습니다. [2017-09-14 08:56:28,123] ERROR java.lang.reflect.InvocationTargetException (com.cantiz.nucleus.kafka.connector.cassandr

0열

1답변

Confluent Rest Proxy API (제작자) 재시도 이벤트가 실패시 게시

Confluent Rest proxy을 모든 사용자 이벤트를 수신하기위한 플랫폼 계층으로 사용하려고합니다 (&). 다양한 유형의 이벤트 생성기가있는 마이크로 서비스 모델 &에서 작업하면서 API/이벤트 생성기를 이벤트 수신/처리에서 분리해야합니다. 또한 이벤트 리스닝 레이어에서는 이벤트 의 탄력성이 중요합니다. 내가 알기로, Rest Proxy 계층이 어떤

0열

2답변

카프카 연결 Elasticsearch - NoSuchMethodError

내가 (사이에 Logstash을주지 않고) 직접 Elasticsearch에 카프카 (V0.11.0.1)에서 주제를 스트리밍하기 위해 지류에서 kafka-connect-elasticsearch 플러그인을 실행하려합니다. $ cd kafka-connect-elasticsearch $ mvn clean package 내가 다음 필요 구성 파일 생성 - -

1열

1답변

zookeeper-shall.sh rmr 브로커/주제를 사용하여 주제를 삭제하는 것과 kafka10의 kafka-topics.sh에서 플래그를 삭제하는 것의 차이점

온라인에서 발견 된 것과 내가 스택에서 발견 한 오버 플로우 게시물에서 주제를 삭제하는 데 주로 두 가지 방법이있는 것 같습니다. 카프카에. 첫 번째 존재한다 : a) delete.topic.enable = true 및 ./kafka-topics.sh ---delete --topic <topicName> 두 번째 방법을 실행 : ./zookeeper-she

0열

1답변

Kafka Connect - Terradata 소스 컨텍 터 및 Oracle 테이블로 업 그레 이드

Terradata에서 테이블을 읽고 Oracle에서 Upsert로 테이블을 읽으려는 데이터 파이프 라인을 만들고 싶습니다. kafka connect teraddata 소스 커넥터를 사용하고 Oracle 싱크 커넥터를 사용하여 Oracle 테이블에 쓸 수 있습니까?

0열

1답변

클러스터 모드에서 Confluent Kafka Schema Registry를 설치하는 방법

설치 : - 우리는 AWS ELB 뒤에 3 개의 스키마 레지스트리 인스턴스가 있습니다. 클러스터 모드에서 스키마 레지스트리를 설정하도록 schema_registry.properties 파일을 변경하는 방법 ELB 엔드 포인트가있는 스키마 레지스트리를 호출 중입니다.

1열

1답변

Kafka Streams가 스키마없이 avro 토픽을 생성했습니다.

저는 Schema Registry를 사용하여 avro 토픽에서 데이터를 읽고 간단한 변환을 수행하고 결과를 콘솔에 인쇄하는 Java 애플리케이션을 개발했습니다. 기본적으로 키와 값에 대해 GenericAvroSerde 클래스를 사용했습니다. 모든 것은 내가 그없이 final Map<String, String> serdeConfig = Collections.

0열

1답변

Kafka/Confluent : ProducerConfig가 고정 막대 이미지를 사용하여 max.request.size 기본값을 변경합니다.

kafka/confluent (3.2.0)를 사용하여 우리가 가지고있는 Mongodb 인스턴스의 변경 사항을 검색하고 있습니다. 소스 프로세스는 Source Connect Api를 사용하는 Debezium source connector으로 관리되며, Confluent Connect 도커 이미지를 확장하는 메소 (DC/OS)를 사용하여 시스템에 배포됩니다.