apache-kafka

0열

1답변

KTABLE의 모든 현재 항목을 쿼리하는 방법이 있습니까? 페이로드로 REST API에 대한 http 요청을 실행하려고합니다. { "ksql": "SELECT * FROM MY_KTABLE;", "streamsProperties": { "auto.offset.reset": "earliest" } } 이며 스트림이

0열

2답변

사육사없이 Java API를 사용하여 카프카 토픽 생성

kafka 0.10.1.x에 대한 사육사 의존성없이 카프카 토픽을 만드는 방법은 java? 주제가 생성 된 스레드를 보았지만 zookeeper, zk 클라이언트 등을 사용했습니다. 이미 kafka 0.10은 사육사를 사용하지 않고 자바 만 사용하고 scala 종속성을 사용하지 않으려합니다.

2열

1답변

고급 가재 패브릭 첫 번째 네트워크가 kafka와 작동하지 않고 TLS 사용

공식 문서에서 첫 번째 네트워크 샘플 Building Your First Network을 실행하려고합니다. 이 샘플을 kafka 발주자 유형으로 실행해야합니다. 나는 (브로커 카프카로 변경 OrdererType 및 추가) configtx.yaml 파일을 편집이 경우 ... # Orderer Type: The orderer implementation to

0열

1답변

Linux에서 kafka를 시작하거나 Win

지난 10 시간 동안 kafka 서버를 시작하려고했지만 시도 할 수 없었습니다. 나는 사육사를 설치하고 win10에서 실행하는 데 성공하지만 난 classpath is empty. please build the project first e.g. by running 'gradlew jarall' 오류가 발생했습니다. 그래서 우분투와 jre 9를 설치했는

0열

1답변

nagios를 사용하여 apache kafka를 모니터하는 방법은 무엇입니까?

nagios를 사용하여 카프카 클러스터를 모니터링 할 수있는 방법이 있습니까? 브로커 상태, 파티션 상태, 메모리 상태, 현재 오프셋 및 클러스터의 모든 중요한 메트릭을 검사 할 수있는 모든 작업 플러그 인, API 또는 기타 사항은 무엇입니까? 우리는 (우리가 JMXeval를 사용하지만, 당신은 Nagios를위한 당신의 마음에 드는 JMX 모니터링 스크립

0열

1답변

Kafka 클라이언트 ID 속성 (봄 구름 스트림 사용)

Spring Cloud Stream을 사용하면 Kafka 클라이언트 ID 속성을 설정할 수있는 방법이 있습니까? 당연히 카프카 바인더를 사용하고 있습니다. 이것을 설정하는 서비스 중 일부가 복제 될 것이므로 인스턴스간에 ID를 고유하게 만들 수있는 방법이 있습니까? (Spring Kafka Consumer Client-Id configuration을 보면

1열

1답변

readStream kafka는 아무런 값도 얻지 못합니다.

spark-shell 내부에서 spark 구조화 된 스트리밍을 통해 kafka 주제를 읽으려고하고 있지만 kafka에서 어떤 라인도 얻지 못하는 것처럼 보입니다. 카프카 혼자 잘 작동 (콘솔 소비자와 콘솔 프로듀서 테스트) : 나는 ' ds1 = spark .readStream .format("kafka") .option("kaf

-1열

1답변

java.lang.ClassNotFoundException : com.datastax.spark.connector.japi.rdd.CassandraTableScanJavaRDD

카산드라와 함께 카프카 스파크 스트리밍을 사용하고 있습니다. 일식을 사용하여 내 Java 클래스를 실행할 때 잘 작동하지만, 내가 maven을 사용하여 빌드하고 Spark Shell에서 실행하면 예외가 발생했습니다. java.lang.NoClassDefFoundError: com/datastax/spark/connector/japi/rdd/Cassandra

0열

1답변

Kafka -이 서버는 해당 항목의 파티션이 아닙니다.

두 개의 중개인 kafka 0.10.2.0 클러스터가 있습니다. 복제 요소는 2입니다.이 카프카에 대해 1.0.0 카프카 스트림 응용 프로그램을 실행 중입니다. 내 kafka 스트림 응용 프로그램에서 생산자 구성은 retries = 10 and retry.backoff.ms = 100 몇 분 후에 Kakfa server.log에서 다음 로그를 관찰했습니다.

1열

2답변

NoClassDefFoundError Flip과 Kafka를 통합하려고 할 때

kafka과 flink을 interegate하려고합니다. 아이디어는 kafka 대기열을 소비하고 flink를 사용하여 데이터를 변환하는 것입니다. 나는 https://github.com/abhishek-ch/evolveML/blob/master/flink/kafka-flink-example/pom.xml 이 내 종속되어 아래에 언급 된 예를 다음과 같은거야