confluent-kafka

-1열

1답변

kafka 커넥터를 사용하는 간단한 사례를 작성하려고했습니다. 셋업에는 세 개의 노드 N1, N2 및 N3이 사용됩니다. N1이 소스이고 N2, N3이 제 경우의 싱크 노드입니다. 노드 N1에서 텍스트 파일 (예 : input.txt)에 데이터를 쓰고 독립형 kafka 커넥터를 사용하면 노드 N2 및 N3의 input.txt와 비슷한 내용의 텍스트 파일을

1열

1답변

커넥터의 작업이 할당되지 않은 상태로 전환되는 시점은 언제입니까?

분산 모드에서 CP3.2를 실행 중이고 "tasks.max": "1"로 정의 된 커넥터 중 일부가 "UNASSIGNED"상태의 작업을 가지고 있습니다. 작업자에게 할당 된 메모리를 늘리고 작업자를 다시 시작하면 문제가 해결되거나 한 명 더 추가 작업자가이를 해결했습니다. "tasks.max"> 1에 "UNASSIGNED"상태의 작업이 하나 있지만 하나의 작

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열

3답변

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

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

0열

1답변

카프카 연결은 - <strong>Conluent 플랫폼/카프카 연결</strong>와 유사한 것들로 소스 커넥터 오류

내가 연주하고 파일과 나는 몇 가지 예제를 실행하고 싶었다. 나는 here에서 빠른 시작을 따랐다. 그것은 의미 설치 플루 플랫폼 (V3.2.1) 실행 사육사, 카프카 중개인 및 스키마 등록 (카프카 연결 witk) 파일 데이터를 읽기위한 실행 예를 내가 달릴 이 명령 (3 번) : [[email protected] confluent-3.2.1]# ./bi

0열

1답변

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

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

1열

2답변

Java 의존성을 어떻게 찾을 수 있습니까?

다음은 this 자습서입니다. 내가 가진 코드는 이것이다 : package com.ipponusa; import org.apache.spark.SparkConf; import org.apache.spark.api.java.JavaSparkContext; import org.apache.spark.streaming.Duration; import or

0열

1답변

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

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

0열

2답변

마스터 슬레이브 모드에서 스키마 - 레지스트리를 실행하는 방법

지금부터는 schema-registry를 단일 노드로 실행하고 있습니다. 내결함성을 제공하기 위해 master-slave 모드에서 schema-registry를 실행하고 싶습니다. 마스터 노드 하나와 슬레이브 노드 하나. 노드를 마스터로 식별하기 위해 추가 속성을 추가해야합니까? 마스터와 슬레이브 구성 (schema-registry.properties)을

1열

1답변

도커로 작성한 카프카 설정

안녕하세요. 현재 Docker로 카프카를 설정 중입니다. 나는 다음과 같은 고정 표시기-작성 파일을 참조 게시 합류 이미지로 설정 사육사와 카프카를 관리했습니다 : version: '2' services: zookeeper: image: confluentinc/cp-zookeeper:3.2.0 container_name: zo