도커로 SCDF를 시작하려고합니다. 그것은 잘 시작하지만 모든 스트림을 배포 할 때 나는 스프링 클라우드 데이터 플로우 서버 로컬 1.1.4 사용하고 응용 프로그램 로그 2017-03-09 15:19:45.864 INFO 62 --- [ main] kafka.utils.VerifiableProperties : Verifying properties
m 윈도우 7 64 비트 시스템에 apache storm을 설정하려고합니다. 내 구성 tickTime=2000
initLimit=5
syncLimit=2
dataDir=C:/Server-Local/zookeeper-3.4.9/data
clientPort=2181
이 storm.yaml storm.zookeeper.servers:
- "l
나는 kafka 및 사육사를 ec2 인스턴스에서 독립 실행 형 모드로 실행하고 있습니다. dev_spark1이라는 주제가 있습니다. ./bin/kafka-console-consumer.sh 172.31.8.226:9092 --zookeeper --topic dev_spark1 Exception in thread "main" org.I0Itec.zkclien
8 개의 파티션과 2 개의 복제본을 가진 카프카 토픽을 제거하려고합니다. 먼저 kafka-topic.sh --delete 명령을 사용하여 해당 항목을 삭제합니다. 그런 다음 zkCli.sh -server slave1 ..... slave3 및 rmr/brokers/topics/MY_TOPIC을 사용했습니다. 그러나 나는 여전히/brokers/topics /
을 변경하는 방법을, 나는 명령을 사용하여 I는 표를 작성하려고하면 CREATE TABLE iteblog(key int, value string) STORED BY 'org.apache.hadoop.hive.hbase.HBaseStorageHandler' WITH SERDEPROPERTIES ("hbase.columns.mapping" =":key,cf1:
아래의 성명서에 문제가 있습니다. server.1=zoo1:2888:3888
server.2=zoo2:2888:3888
server.3=zoo3:2888:3888
위의 문이 을 무엇을 의미합니까 난 내가 server.1에 대한 인수로 전달해야 이것이 사용되는지 이해하지 못했다으로 문 zoo1을 실행 시도하지 않은 I 패스와 u는 예제를 통해 설명
내 node.js 서버에서 node-zookeeper-client을 사용하고 있습니다. getData 메서드를 사용하여 znode 데이터를 보려고하면 처음 실행시 올바르게 작동합니다. 문제는 노드를 업데이트 할 때 (ZK-Web 사용자 인터페이스 사용)입니다. watcher는 처음 데이터를 업데이트 할 때만 호출합니다. 다시 업데이트하면 호출되지 않습니다.
복제 (재해 복구) 용 다중 데이터 센터 HBase 클러스터를 계획 중입니다. 클러스터 1 또는 마스터 클러스터는 다른 DC의 슬레이브 클러스터에 복제됩니다. 이러한 설정에서 두 클러스터는 다른 동물원을 사용하거나 두 데이터 센터에서 액세스 할 수있는 일반적인 동물원 인스턴스를 가리켜 야합니까? 가장 좋은 전략은 무엇입니까?
우리의 라우팅 전략은 "router":{"name":"compositeId"},이었습니다. 뭔가 메시징을 받고 현재 라우팅 전략이 "router":{"name":"implicit"}},으로 설정되었습니다. 으로 모든 레코드 및 변경 라우팅 전략을 purge으로 지정하고 싶습니다. 간단히 레코드를 제거하고 ClusterState.json을 변경할 수 있으며