apache-kafka

0열

1답변

KAFKA와 STORM을 모두 포함하는 샘플 프로젝트를 다운로드 할 웹 사이트를 찾고 있습니다. NoSQL을 사용하는 것이 좋습니다. 아무도 도와 줄 수 없나요? 이에 작동하는 방법에 대한 자세한 설명이있다 https://github.com/svendx4f/stormRoomOccupancy : 안부

2열

3답변

카프카와 파이썬 - 나는 워드 프로세서

을 소비하는 방법을 얻을 해달라고 .. [1] : https://github.com/mumrah/kafka-python # To send messages asynchronously producer = SimpleProducer(kafka, async=True) producer.send_messages("my-topic", "async message")

9열

2답변

카프카는 보안 통신을 지원합니까?

많은 아파치 카프카 문서를 읽었지 만, 카프카가 프로듀서 - 중개인, 중개인 - 소비자 간 보안 통신을 지원하는지, 특히 중개인 복제를위한 데이터 센터 간 통신을 위해 지원되는지는 알 수 없습니다.

8열

3답변

Kafka 0.8 Log4j appender 사용 방법

Kafka-0.8 Log4j appender를 실행하려고하는데 할 수 없습니다. 내 응용 프로그램이 log4j appender를 통해 kafka로 직접 로그를 보내길 원합니다. 여기 내 log4j.properties입니다. 적절한 인코더를 찾을 수 없었으므로 기본 인코더를 사용하도록 구성했습니다. (예 : 댓글을 달았습니다.) log4j.rootLogger

1열

1답변

파이썬과 카프카 KeyError : -1

파이썬 카프카가 작동하지 않습니다. 이유가 뭐야? 내가 이벤트를 카프카에 연결하지 못할 경우 오류가 발생합니까? 0.8과 함께 작동하는 카프카 클라이언트가 있습니까? 이것은 새로운 서버라는 의미입니다. 방금 부팅 했어. 나는 카프카 로그에서 https://github.com/mumrah/kafka-python from kafka.client import K

5열

2답변

Eclipse scala.object를 확인할 수 없습니다.

Eclipse에서 Kafka 제작자 및 소비자 코드를 Java로 작성하려고합니다. 카프카 jar 파일을 다운로드하고 외부 Jar 파일로로드했습니다. 그리고 그것은 의존성 문제를 해결했습니다. 그러나, 항상 해결되지 않은 오류가 있고 메시지는 다음과 같습니다 Multiple markers at this line - The type scala.Product

4열

1답변

"run-example"스크립트가없는 Spark Kafka wordcount.java 예제를 실행하십시오.

저는 Kafka에서 데이터를 스트리밍하는 Spark에서 단어 수를 예로 실행하려고합니다. Source Code Here. 그러나 Cloudera Spark 배포본은 인큐베이터와 조금 다릅니다. 스파크 셸을 실행하는 데 문제가 없으며 거기에서 단어 개수 예제를 실행합니다. 그러나 bin 폴더에는 "run-example"스크립트가 없으며 예제 소스 코드에 나와

0열

1답변

비동기 goroutines가있는 카프카 소비자

나는 내 소비자를 위해 카프카 0.8.0과 함께 sarama (https://github.com/Shopify/sarama/)를 사용하고있다. 이것은 내 코드는 모습입니다 : consumerLoop: for { select { case event := <-consumer.Events(): if event.Err != nil

1열

1답변

storm-deploy 토폴로지 제출 로컬 클러스터에서 토폴로지를 실행 한 후

원격 스톰 클러스터를 만들었습니다 (폭풍 배포 Nathan). 나는 "패키지 의존성"을 가진 runnable 항아리를 만들기 전에 eclipse에서 빌드 경로에서 Storm jar를 제거했다. 내 토폴로지는 storm-kafka-0.9.0-wip16a-scala292.jar를 사용하는데, 이는 빌드 경로에 남겨두고 runnable jar를 만들기 전에 빌드

0열

1답변

카프카 주제를 만들기 위해 꼭두각시 권장 모듈이 있습니까?

카프카 주제를 만들 때 권장되는 인형극 모듈이 있습니까? 도움을 주셔서 감사합니다.