confluent-kafka

0열

1답변

java - Debezium은 DDL (create proc) 문을 구문 분석 할 수 없습니다. mysql connector

나는 Kafka에 debezium 커넥터를 통합하여 내 mysql db 변경을 스트림합니다. 일부 절차의 경우 binlog 파일을 읽을 수 없습니다. 어떤 제안이나 해결 방법? 이 prob로 붙어있어. mysql에서 ddl 로그를 binlog 파일에 저장하지 않도록 지정할 수 있습니까? 2017-10-10 15:20:22,314 ERROR MySQL|dbS

apache-kafka-connect confluent-kafka debezium 2017-10-10

---

0열

2답변

합치기 kafka 연결을 사용하는 ETL

합법적 인 Kafka를 사용하여 소스 및 싱크 데이터에 연결하는 유스 케이스가 있습니다. 전형적인 ETL과 같습니다. Kafka connect가 이전 스트림 간의 델타 변경을 식별 할 수 있는지 이해하고 싶습니다. 즉, 변경된 데이터 만 클라이언트로 보내고 전체 표 또는보기는 보내지 않기를 원합니다. 또한 소스 및 대상 DB에 대한 쿼리를 통한 변경을 식별

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

---

1열

1답변

Confluent Kafka의 재생 메시지

봄 부팅시 합류 kafka 스택을 사용하고 있으며 서비스를 시작하고 특정 시간으로 메시지를 다시 재생할 수있는 기능을 추가하려고합니다. 소비자는이 public interface ProductScenarioStream { String SERVICE_REQUESTS_PRODUCT_PRICE = "serviceRequestsProductPrice";

java spring-cloud-stream spring-kafka confluent-kafka 2017-10-24

---

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

Avro 시리얼 라이저와 스키마 레지스트리를 사용하여 카프카에게 메시지를 보내는 방법

Avro 시리얼 라이저와 스키마 레지스트리를 사용하여 카프카에 객체를 보내려고합니다. 여기에 단순화 된 코드 : Properties props = new Properties(); ... props.put(KEY_SERIALIZER_CLASS_CONFIG, "org.apache.kafka.common.serialization.StringSe

apache-kafka avro confluent-kafka confluent-schema-registry 2017-10-31

---

1열

1답변

Kafka의 메시지 헤더 (.NET)

올바르게 이해하면 confluent-kafka-dotnet (Confluent.Kafka 패키지, 버전 0.11.2)의 현재 버전은 message headers으로 메시지 게시/읽기를 지원하지 않습니다. .NET에서 메시지 헤더를 사용하는 방법이 있습니까? 가까운 미래에이 기능을 사용할 수 있습니까?

.net apache-kafka .net-core confluent-kafka 2017-11-01

---

0열

1답변

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

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

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

---

0열

1답변

RdKafka Avro Consumer

C# RdKafka 클라이언트에서 Avro 메시지를 읽어야합니다. --property schema.registry.url = http://localhost:8081 내가 클라이언트의 구성에이 속성을 넣을 수 있습니다 방법 : 콘솔 명령에서 나는이 속성을 사용하고 있습니다? Confluent.Kafka 찬성 var config = new Config() {

c# confluent-kafka 2017-09-21

---

1열

1답변

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

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

apache-kafka confluent-kafka confluent 2017-09-27

---

1열

1답변

카프카가 생성시 오프셋을 0으로 반환

confluent-kafka-go을 사용하여 골란에 기본 채널 기반 프로듀서를 작성하고 단일 파티션 단일 브로커 kafka를 합류를 통해 설정했습니다. acks을 통해 반복되는 동안 생성되는 경우 성공적으로 생성 된 메시지의 오프셋은 으로 수신됩니다. 샘플 로그 : { "수준" : "정보", "MSG", "시간" "항목 테스트를 성공적으로 게시가, 0, 파

go apache-kafka kafka-producer-api confluent-kafka 2017-10-03

---