apache-kafka-connect

3열

1답변

avro 파일에 저장된 org.apache.kafka.connect.data.Decimal을 어떻게 파이썬 유형으로 변환 할 수 있습니까?

는 내가이에 해당 할 수있는 파이썬 3 원시적 형 확실하지 않다 파이썬 { "name": "id", "type": { "type": "bytes", "scale": 0, "precision": 64, "connect.version": 1, "connect

python apache-kafka apache-kafka-connect debezium 2017-10-23

---

0열

1답변

kafka에서 elasticsearch로 데이터를 가져올 때 가져 오기 진행률 및 오류 로그를 가져 오는 방법은 무엇입니까?

배경는 : 나는 elasticsearch하는 카프카에서 데이터를 가져 오기 위해 노력하고있어, 클라이언트 2 종류가있다. 하나는 웹 클라이언트이고 다른 하나는 에이전트 클라이언트입니다. 웹 클라이언트는 사용자가 업로드 할 때 csv 파일을 처리하고 웹 클라이언트는 csv 파일에서 매 10,000 행을 읽고 csv 총 행 수가 Producer 인 데이터 메시

elasticsearch apache-kafka spark-streaming apache-kafka-connect 2017-10-26

---

0열

1답변

카프카 합류 JDBC 커넥터가 유효하지 않은 값

나는 kafka jdbc 합류 커넥터 3.x를 사용하여 Oracle에서 데이터를 가져 와서 Kafka 서버에 게시했습니다. 속성 파일 구성은 다음과 같습니다. name=demo-jdbc-source connector.class=io.confluent.connect.jdbc.JdbcSourceConnector connection.url=jdbc://db_

apache-kafka apache-kafka-connect confluent-kafka 2017-10-26

---

0열

1답변

Kafka 합류 플랫폼 3.3 WARN 노드 -1 연결을 설정할 수 없습니다. 브로커를 사용할 수 없을 수도 있습니다.

Kafka 독립 실행 형 커넥터를 시작하는 중에 오류가 발생하는 중입니다. WARN Connection to node -1 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:589) 카프카 서버 사육사와 합류 플랫폼 사육사가 다른 포트

java apache-kafka apache-kafka-connect confluent 2017-10-30

---

0열

1답변

서블릿을 사용하여 KafkaProducer를 연결하십시오.

서블릿을 사용하여 KafkaProducer를 연결하고 Eclipse에서 프로젝트를 설정하려고합니다. 난 KafkaProducer 실행할 때하지만 예외가 : org.apache.catalina.core.StandardWrapperValve 심한 호출 : 경로 컨텍스트 에 서블릿 [simple_kafka.SimpleProducer]의 의 Servlet.serv

apache-kafka kafka-producer-api apache-kafka-connect 2017-10-31

---

0열

2답변

원격 컴퓨터 용 Confluent hdfs sink connector를 구성하는 방법은 무엇입니까?

'A'카프카 머신에서 'B'하둡 머신으로 hdfs 싱크 커넥터를 구성하는 방법 어떻게 하죠? 좋은 예가 있습니까?

apache-kafka apache-kafka-connect 2017-11-01

---

0열

1답변

데이터가 카프카 서버에 푸시 된 후 데이터를 삭제합니다.

Oracle 데이터베이스에서 데이터를 가져 오기 위해 합류 플랫폼 3.3을 사용하고 있습니다. 일단 데이터가 카프카 서버로 보내지면 검색된 데이터는 데이터베이스에서 삭제되어야합니다. 어떤 방법이 있습니까? 제발 제안 해주세요.

java apache-kafka bigdata apache-kafka-connect confluent-kafka 2017-11-02

---

0열

2답변

Apache Kafka를 사용하여 MySQL 테이블 쿼리하기

유스 케이스 달성을 위해 카프카 스트림을 사용하려고합니다. MySQL에는 사용자 및 계정이라는 두 개의 테이블이 있습니다. 그리고 MySQL에서 Kafka MySQL 커넥터를 사용하여 Kafka로 이벤트를 가져 왔습니다. 카프카 자체에서 계정 내의 모든 사용자 ID를 가져와야합니다. 그래서 MySQL 출력 항목에 KStream을 사용하여 출력을 구성하고이를

apache-kafka apache-kafka-streams apache-kafka-connect ksql 2017-11-02

---

0열

1답변

Kafka-Connect를 시작할 수 없습니다.

"./bin/connect-standalone ./etc/kafka/connect-standalone.properties ./etc/kafka"명령으로 kafka-connect를 시작하는 동안 다음 오류가 나타납니다. -connect-elasticsearch/quickstart-elasticsearch.properties "를 참조하십시오. 따라서 kafk

elasticsearch apache-kafka apache-kafka-connect 2017-11-02

---

1열

1답변

kafka couchbase sink 커넥터가 일부 레코드를 덤프 한 후 연결이 끊어졌습니다.

confluent_3.3.0을 설치하고 zookeper, schema-registry 및 kafka broker를 시작했습니다. 아래 링크 https://github.com/couchbase/kafka-connect-couchbase 에서 그리고 다운로드 카우치베이스 주식회사 커넥터가 커넥터를 실행 한 후 명령 ./bin/connect-standalone

apache-kafka couchbase apache-kafka-connect sink 2017-11-07

---