confluent

0열

1답변

Spring Cloud Stream을 사용하여 Confluent Schema Registry를 사용하여 Avro 메시지를 생성하고 소비하는 방법은 무엇입니까?

나는 Start Streaming with Kafka and Spring Cloud을 따라 예제를 실행할 수 있지만, 안타깝게도 합류 스키마 레지스트리를 사용하지 않습니다. 합류 스키마 레지스트리 부분을 Spring Cloud Stream reference guide으로 읽었지만 합류 3.0.0에서는 작동하지 않았고 합류 스키마 레지스트리를 사용하여 Avr

1열

2답변

Kafka에서 잘못된 시간을 읽는 StreamSets 데이터 수집기

StreamSets 데이터 수집기가 잘못된 datetime 값을 읽는 것 같습니다. Confluent에서 간단한 주제를 읽었습니다 : Landoop Kafka 항목으로 밀리 초 단위로 날짜/시간 값을 확인할 때 올바른 datetime을 표시하지만 StreamSet에서 Kafka Consumer 0.10.0.0으로 읽을 때 - 날짜 시간은 3 시간입니다. 그

0열

1답변

Spring 합치도 스키마 비 직렬화 예제

spring-kafka 2.0.0.Release를 사용하고 컨플릭트 스키마 레지스트리를 메시지를 비 직렬화하는 소스로 사용하는 소비자를 만들었습니까? 그렇다면 예제를 가르쳐 주시겠습니까? 내가 해결하려고하는 문제는 MFC에서 발생하는 이벤트를 스트림하는 kafka 연결 플랫폼에 Debezium CDC 커넥터가 있다는 것입니다. 이러한 이벤트를 변환하고 다시

0열

1답변

는

나는 카프카의 토폴로지 다음과 같은 정의 Operation 1 : input_stream ----> filter ----> window_processing ----> write_to_topic Operation 2 : input_stream ----> write_to_topic 나는 두 작업은 동일한 스레드 (내가 스레딩에 대한 StreamsConfi

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) 카프카 서버 사육사와 합류 플랫폼 사육사가 다른 포트

0열

1답변

confluent-kafka-python 제작자 및 소비자의 error_cb

error_cb 콜백이 호출되는 evens에 대한 적절한 반응이 무엇인지 궁금합니다. 처음에는 우리 코드가 무엇이든간에 error_cb의 예외를 던졌습니다. 우리는 Kubernetes에서 물건을 사용하고 있으므로 소비자/생산자를 재시동하는 것은 (기술적으로) 큰 문제가 아닙니다. 그러나 다시 시작의 수는 매우 중요했다, 그래서 우리는 종료하지 않고 우리가

0열

1답변

Confluent 플랫폼 - 기본 명령에 sudo가 필요합니까?

AWS linux server running (centOS 7.x)에서 오픈 소스 컨플룩트 플랫폼을 시험해보고 있습니다. 냠 루트로 OSS (오픈 소스 버전) 버전에 설치하고 후에는 confluent start 명령을 사용하여 서비스를 시작하는 매우 정직했다. 내가 가진 질문은 - 루트가 아닌 사용자와 동일한 서버에 로그인 할 때 아래 명령을 실행하려고

0열

1답변

카프카 스트림을 사용할 때 메시지의 ID를 생성하는 방법은 무엇입니까?

합창 카프카에서 많은 글을 읽은 후에 정상적인 채팅 시스템을 구현하려고합니다. 그러나 몇 가지 구조 설계를 할 때 몇 가지 문제를 만났습니다. mysql을 데이터의 db로 사용할 때 사용자 테이블의 user_id, 메시지 테이블의 message_id와 같은 의미있는 모든 메시지에 id을 줄 수 있습니다. 모델 테이블에 ID를 부여한 후 클라이언트와 서버가

0열

1답변

환경 변수 대신 속성 파일을 사용하여 합숙 도커 이미지를 시작/구성 할 수 있습니까?

The docs은 cp-zookeeper 및 cp-kafka 이미지가 환경 변수를 통해 구성되어 있다고 설명합니다. ZooKeeper 이미지는 zookeeper.properties 파일에 나타나는 변수와 정확히 일치하는 변수를 ZOOKEEPER_로 시작하는 변수를 사용합니다. 예를 들어, clientPort와, tickTime을 설정하고 syncLimit

0열

1답변

org.apache.kafka.common.KafkaException : io.confluent.kafka.serializers.KafkaAvroSerializer

코드 import org.apache.kafka.clients.consumer.ConsumerConfig; import org.apache.kafka.clients.consumer.ConsumerRecord; import org.apache.kafka.clients.consumer.ConsumerRecords; import org.apache.kafk