confluent

0열

1답변

플루 카프카 내가 합류를 사용하고 elasticsearch 문서 ID 생성

연결 :에 org.apache.kafka.connect.errors.DataException: STRUCT is not supported as the document id. at io.confluent.connect.elasticsearch.DataConverter.convertKey(DataConverter.java:75) at io.c

2열

1답변

그룹 (Kafka)의 코디네이터 표시

몇 시간 전에 내 서비스 중 하나가 작동을 멈췄습니다. 서버를 다시 시작했지만이 소비자 프로세스가 Kafka에 등록하지 않았습니다. 소비자가 시작될 때 표시되는 내용입니다. 2017-04-21 10:22:54.887 INFO 18036 --- [afka-consumer-1] o.a.k.c.c.internals.ConsumerCoordinator : Revo

0열

1답변

카프카 싱크 연결 - 주제 당 하나의 작업 생성 방법 (테이블)

카프카 항목에서 해당하는 암페어 표로 데이터를 수집하는 암 푸 ADS라는 제품 용 카프카 싱크 커넥터를 구현했습니다. 주제와 표는 이름별로 매핑됩니다. 개별 주제 (주제에서 섭취 ---> 표)를 전용 싱크 작업으로 처리해야합니다. 그래서 내 설정은 3 개 가지 주제 (항목 1, 항목 2, topic3)이 포함되어있는 경우, 예를 들어, 싱크 커넥터는 3 개

0열

1답변

파이썬을 사용하여 카프카에 avro 데이터 쓰기

카프카 토픽에 avro 데이터를 쓰려면 'confluent-kafka-python'client를 사용하고 있습니다. 나는 데이터를 서면으로 작성했습니다,하지만 난 사용하여 데이터를 읽을 때 : [2017-05-02 13:38:11,387] ERROR Unknown error when running consumer: (kafka.tools.ConsoleCon

0열

3답변

Kafka 스트림으로 개발할 때 Lib에서 불완전한 LinkError가 발생하면 DB dll이 발생합니다.

개발 용 Windows 컴퓨터에 Kafka Streams 응용 프로그램을 쓰고 있습니다. 나는 단지 응용 프로그램을 실행할 때 다음 오류 얻을 카프카 스트림의 leftJoin 및 branch 기능을 사용하려고하면 : 그것은 카프카처럼 보인다 Exception in thread "StreamThread-1" java.lang.UnsatisfiedLinkErr

0열

1답변

합류 카프카 - 연결 - JDBC java.lang.NullPointerException이

내 MySQL 데이터베이스와 카프카를 연결하는 소스로 합류의 카프카 - 연결 - JDBC를 사용하고 난 아래이 오류를 만났다 : 나를 위해 java.lang.NullPointerException at io.confluent.connect.jdbc.source.TimestampIncrementingTableQuerier.extractOffset(Ti

3열

1답변

일관되지 않은 커넥터 상태 : ConnectException :이 작업자에 이미 작업이 있습니다.

Confluent Platform 3.2를 사용하고 있습니다. 3 개의 다른 EC2 기계에서 3 명의 작업자를 실행합니다. 나는 몇 분 후에 삭제하고 다시 시작한 커넥터 (debezium/MySQL 소스)가 있습니다. 그러나 아래 오류로 인해 성공적으로 커넥터를 시작할 수 없었습니다. 커넥터가 실패한 상태입니다. 나는이 문제를 해결하기 위해 노동자들을 다시

0열

1답변

설치된 컨 플루 언트 플랫폼의 버전을 확인하는 방법

Linux 컴퓨터에 설치된 컨플 루 언트 플랫폼의 버전을 어떻게 확인할 수 있습니까? 문제점을 디버깅하려면 정확한 주 버전과 부 버전을 알아야합니다. 모든 지원에 감사드립니다.

0열

1답변

Confluent Kafka를 사용하여 소비자의 메시지 처리 오류를 처리하는 방법은 무엇입니까?

저는 JMS 기반 시스템에서 새 시스템과 레거시 시스템 간의 트랜잭션을 동기화하는 책임이있는 Kafka로 이동하고 있습니다. 새 시스템에서 게시 한 모든 메시지는 구독자/소비자가 성공적으로 처리해야합니다. 나는 메시지의 순서에 대해 걱정할 필요가 없다. 레거시 시스템에서 일부 설계 문제 (비관적 인 잠금)로 인해 메시지가 도착할 때 트랜잭션이 거의 실패하지

0열

1답변

Avro 스키마를 Confluent Schema-Registry에 저장

Postman을 사용하여 매우 간단한 스키마를 레지스트리에 쓰려고하는데 등록하는 데 어려움을 겪고 있습니다. 이 전체 프로세스의 첫 번째 단계에 불과한 간단한 스키마를 등록하는 것이 실제로 복잡합니까? 아니면 여기에 뭔가 빠져 있습니까? 내가 사용하고 스키마는 다음과 같습니다 : Internal Server Error com.fasterxml.jackson