apache-kafka

2열

1답변

파이썬 로깅 모듈을 많이 사용하는 복잡한 애플리케이션이 있습니다. 이러한 로그를 Kafka 클러스터에 넣기 시작해야하며 그 과정에서 데이터를 변경하지 않아야합니다. 나에게 가장 이상적인 솔루션은 Kafka 용 새 처리기를 만드는 것입니다. 이전 로깅 솔루션과 kafka를 한동안 병렬로 사용할 수 있습니다. 그런 다음 이전 로깅 처리기를 종료하고 카프카에게

1열

2답변

관리자 모드의 카프카

카파를 감시 모드로 실행하여 시스템 종료시 자동으로 시작할 수있게하려고합니다. 그러나 실행중인 kafka의 모든 예제는 쉘 스크립트를 사용하며 supervisord은 모니터 할 PID를 기록 할 수 없습니다. kafka의 자동 재시작을 수행하는 방법을 제안 할 수 있습니까?

2열

1답변

카프카 소비자 그룹은

내가 메시지 그것 "스트림) (최종 KafkaStream 스트림은"에서, https://cwiki.apache.org/confluence/display/KAFKA/Consumer+Group+Example에서 예에서 대기 (메시지를 기다리는 걸려 나타납니다 기다리고 달려 있습니다 카프카의 ConsumerGroupExample 소비자를 실행하고 중단 구성 세부

1열

1답변

건물 아파치 카프카

나는 스카라 2.10.1로 카프카를 만들려고한다. 나는 힘내라 - 허브에 주어진 다음 단계를 시도했다. 결국 Jar 파일은 대상 디렉토리에 Jar 파일을 생성하지만 Jar 파일은 비어 있고 크기는 5kb입니다. 내가 여기서 뭔가를 놓치고 있니? 나는 SBT에 완전히 새로운 사람이다. 1) (스칼라의 특정 버전을 구축하기 위해 3) ./sbt 어셈블리 패키지

4열

1답변

클로저에 스칼라 개체를 만드는 방법

클로저에 스칼라 개체 인 kafka.utils.ZKStringSerializer을 만들려고합니다. (org.apache.kafka/kafka_2.10 "0.8.0"에 있음) 저는 스칼라에 대해 거의 알지 못하기 때문에 생성자를 호출하는 방법을 알지 못합니다. (import 'kafka.utils.ZKStringSerializer) (ZKStringSeri

6열

4답변

카프카에서 만드는 제작자는 몇 명입니까?

대용량 실시간 자바 웹 앱에서 나는 apache kafka에게 메시지를 보내고 있습니다. 현재 하나의 주제로 보내고 있지만 나중에 여러 주제로 메시지를 보내야 할 수도 있습니다. 이 경우 필자는 주제별 제작자를 생성 할 날씨가 좋지 않거나 모든 주제에 대해 단일 제작자를 사용해야합니까? 당신이 볼 수 있듯이 props = new Properties();

2열

1답변

UnsatisfiedLinkError kafka에 압축 된 (snappy) 메시지를 보낼 때

내 Java 웹 앱에서 메시지를 kafka으로 보내고 있습니다. 내가 너무 내 생산 속성에서 설정하고있어 보내기 전에 내 메시지를 압축하고 싶은 : props.put를 ("compression.codec", "2"); 내가 알고있는 것처럼는 "2"물어을 의미하지만, 메시지를 보낼 때 나는군요 : <dependency> <groupId>org.xe

16열

2답변

kafka 8 및 메모리 - Java Runtime Environment가 계속 실행될 수있는 메모리가 부족합니다.

512 메가의 RAM이있는 DigiOcean 인스턴스를 사용하고 있는데, kafka에서 아래와 같은 오류가 발생합니다. 나는 자바 능숙 개발자가 아니다. 소량의 램을 사용하려면 카프카를 어떻게 조정해야합니까? 이것은 개발자입니다. 나는 더 큰 기계를 위해 시간당 더 많은 것을 지불하고 싶지 않다. # # There is insufficient memory

4열

1답변

소비자 그룹이 클러스터의 다른 노드로 확장 될 수 있습니까?

높은 수준의 소비자 (소비자 그룹)가 동일한 프로세스 내에서 많은 스레드를 사용하여 주제를 소비하는 사례를 많이 보아 왔습니다. 서로 다른 컴퓨터에있는 여러 프로세스가 파티션을 분할하여 병렬로 사용할 수 있습니까? 그렇다면 예제가 있습니까?

5열

2답변

주제 작성 오류 Windows 7의 카프카

여러 번 다시 시도하고 bat 파일을 변경 한 후 마침내 Windows 7에서 Kafka 및 Zookeeper를 실행하는 데 성공했습니다. 이것은 Java 7을 실행하는 32 비트 시스템입니다. 주제를 만들 수 없습니다. http://janschulte.wordpress.com/2013/10/13/apache-kafka-0-8-on-windows/ 내가 명