apache-kafka

5열

1답변

kafka cant가 zookeeper-FatAL에 연결합니다. KafkaServerStartup 시작 중 치명적인 오류가 발생했습니다.

세계 각지의 서비스가 내 동물원에 연결하여 kafka를 기대할 수 있습니다. 다음은 server.properties에서 내 연결 문자열 zk.connect=1.dzk.syd.druid.neo.com:2181, 2.dzk.syd.druid.neo.com:2181 두 사육사 서버 .... 전체 무차별 모드의 모든 포트를 가지고 파일입니다. 난 telnet

0열

1답변

Java로 작성한 콘솔에서 Kafka Producer를 실행하는 방법은 무엇입니까?

So i have a project in java which has this structure !![directory struct](http://postimg.org/image/vqn69s6tn/) TESTPROD.java를 컴파일하려면 kafka의 스칼라 파일에 많은 의존성이 있으므로 어떻게해야합니까?

1열

1답변

Simple Consumer of Java의 Kafka가 반환 한 ByteBufferMessageSet에서 OffSet을 가져 오는 방법은 무엇입니까?

다음 코드를 고려하십시오 public static long Offset = 0L; FetchRequest req = new FetchRequest(KafkaProperties.topic, 0, Offset,10485760); ByteBufferMessageSet messageSet = simpleConsumer.fetch(req); 문제는 마지막 오

3열

3답변

카프카 자바 프로듀서를 사용하여 메시지 보내기 : 로컬 호스트에 프로듀서 연결 : 9092 실패

카프카 서버에 메시지를 보내려고합니다. 브로커 목록에 localhost가 포함되어 있지 않습니다. 로컬 호스트에 프로듀서 연결 : 생산은 send 메소드를 호출 할 때, 그것의 예외가 9092 실패를 import kafka.javaapi.producer.Producer; import kafka.producer.KeyedMessage; import kaf

6열

2답변

메시지가 소비 또는 처리되면 내가 정확히 카프카에서 승인을받는 방법 카프카

의 승인을 얻는 방법. 어리석은 소리일지도 모르지만, ack가 수신 된 메시지의 시작과 끝 오프셋을 알 수있는 방법이 있습니까?

5열

2답변

Apache Kafka 소비자 그룹 및 단순한 소비자

저는 카프카를 처음 접했고 소비자에 관해서는 기본적으로 두 가지 유형의 구현이 있다는 것을 이해했습니다. 1) The High level consumer/consumer group 2) Simple Consumer 높은 수준의 추상화에 대한 가장 중요한 부분은 카프카가 처리하는 것에주의하지 않는 때 사용되는 단순 소비자가 오프셋 관리를 통해 더 나은 제어를

1열

1답변

이클립스에서 Kafka 소스 코드를 실행할 때의 문제

상황 : 나는 Kafka 프로젝트를 올바로 실행하고 Linux 명령 줄에서 "빠른 시작"을 실행해도 아무런 문제가 없습니다. 그런 다음 스칼라 프로젝트 (Kafka는 스칼라에 있음)를 빌드하고/core 디렉토리에 소스 코드를 가져 와서 패키지를 빌드 경로에 넣고 오류가있어서 main에 패키지를 가져 오려고했습니다/ 여기에 코어의 디렉토리입니다 : 수입 후

3열

4답변

Kafka Storm HDFS/S3 데이터 흐름

Flume 에서처럼 카프카에서 팬 아웃 (복제)이 가능한지 확실하지 않습니다. 카프카에게 HDFS 또는 S3 데이터를 저장하고 실시간 처리를 위해 스톰에 해당 데이터의 사본을 보내고 싶습니다. Storm 집계/분석 결과는 Cassandra에 저장됩니다. 카프카에서 스톰으로 모든 데이터를 전송 한 다음 스톰에서 두 개의 결과를 전달하는 일부 구현을 봅니다.

5열

2답변

카프카 스톰 (Kafka Storm) 통합 카프카 스파우트 (Kafka Spout) 사용

나는 KafkaSpout을 사용하고 있습니다. 아래 테스트 프로그램을 찾으십시오. 폭풍우 0.8.1을 사용 중입니다. Multischeme 클래스는 Storm 0.8.2에 있습니다. 나는 그것을 사용할 것이다. 난 그냥 StringScheme() 클래스를 인스턴스화하여 이전 버전이 어떻게 작동하는지 알고 싶습니까? Kafka Spout의 이전 버전은 어디서

1열

2답변

카프카 0.8 좋은 & 바위! .... 카프카 0.7은 그럴 수 없었습니다

카프카 0.8 작품. CLI를 사용할 수있을뿐만 아니라 내 자신의 제작자/소비자를 쓸 수 있습니다! Zookeeper를 확인하는 중 ... 0.8에 대해 성공적으로 만들어진 모든 토픽과 파티션을 봅니다. 카프카 0.7이 작동하지 않습니다! 왜 카프카 0.7입니까? 나는 Kafka 0.7 용으로 제작 된 Storm의 Kafka Spout을 사용하고 있습니다.