apache-kafka

4열

2답변

KeeperErrorCode =/brokers/topics/test-topic/partitions에 대한 NoNode가

이 오류가 발생하는 Kafka를 시작하는 중. KeeperErrorCode = NoNode for /brokers/topics/test-topic/partitions 도움이 될 것입니다.

1열

2답변

지연된 작업을 kafka에 어떻게 추가합니까? 내가 알기로는 메시지별로 처리하지는 않지만 주제별로 처리하지는 않습니다. 내 직업은 그들이 소비되기를 원하는 다양한 일정을 가지고 있습니다. 다음 4 시간 안에, 다른 하나는 12 월 1 일이 될 것이라고 말하십시오. kafka는 이것을 달성하기위한 제 3 자의 다른 방법을 원천적으로 지원합니까? 지연된 대기열

0열

1답변

Mesos & Kafka : mesos 클러스터에서 여러 카프카 브로커를 구성하고 실행하는 방법은 무엇입니까?

Kafka 0.9 출시를 위해 Mesos API와의 기본 통합이 계획되어 있다는 것을 알고 있습니다. 한편 마라톤을 사용하여 카프카 중개인을 운영하고 규모를 키우는 것이 좋을 것입니다. 아무도 이미 그것을하고 경험이 있습니까?

0열

1답변

spring-integration-kafka 스프링에 STOP 아이콘이 표시되지 않음 STS 통합 그래프 탭

현재 Spring Tool Suite (버전 : 3.6.3.CI-B2266066, 빌드 ID : 201411050946, 플랫폼 : Eclipse Luna SR1 (4.4) .1))와 스프링 통합 4.0.3. 내 프로젝트에 spring-integration-kafka 브랜치 1.1.0을 가져 왔고 Spring 구성 XML 내에서 int-kafka : inb

0열

1답변

vertex를 사용하여 카프카 토픽 만들기

vert.x를 사용하여 다른 주제에 대해 생성자를 만드는 방법은 무엇입니까? Vert.x zanox 모듈은 꽤 효과가 있었지만 한 가지 주제로만 제한된 것으로 보입니다. 원하는 주제에 메시지를 보낼 방법이 없습니다. 그것은 config 파일에서 우리가 준 주제에 집중되어 있습니다.

5열

1답변

Java에서 Kafka ZKStringSerializer를 만드는 방법은 무엇입니까? API를 통해 카프카 항목을 작성하는 방법을 찾기 위해

, 나는 스칼라에서이 예제를 발견 import kafka.admin.AdminUtils import kafka.utils.ZKStringSerializer import org.I0Itec.zkclient.ZkClient // Create a ZooKeeper client val sessionTimeoutMs = 10000 val connectio

7열

1답변

Kafka - 최신 오프셋을 얻는 가장 간단한 방법

kafka 항목에 대한 구독을 동적으로 추가 및 제거 할 수있는 응용 프로그램을 구축하고 있습니다. 토픽 구독이 추가 될 때마다 매 시간마다 배치 작업을 실행하여 모든 새 메시지를 가져 와서 다른 데이터 스토어로 푸시했습니다. 내가 알고 싶은 것은 토픽의 현재 오프셋을 얻는 방법입니다. 구독이 추가 되 자마자 다음 번 작업이 구독의 대략적인 시간 이후 모든

0열

1답변

SASL 구성 실패 : 나는 폭풍 토폴로지를 실행하기 위해 kafaTestServer에 연결하려고 Arquillian 통합 테스트

에서 RemotingLoginModule을 찾을 수 없습니다. 은 내가 arquilian 통합 테스트를 실행하고 나는이 오류가 계속. 내 jaas.conf를 실패하는 이유는 RemotingLoginModule 클래스를 찾을 못할 이유 확실하지. 로그인하려고하면 내 자격 증명이 비어 있으며 내 사용자 이름은 null입니다. 31163 [Thread-100]

1열

1답변

스톰 및 카프카 : 열린 파일 설명자의 증가량이

현재 스톰과 함께 카프카를 사용하는 데 문제가 있습니다. 며칠 전까지는 Windows 컴퓨터를 사용했지만 이제는 Mac을 사용하는 것으로 바뀌 었습니다. 내 카프카 대기열이 약으로 채워져 있습니다. 4,800,000 메시지. 이제 약 1 시간 후에 발생합니다. 4600 개의 메시지 처리 나는 10240 개의 열린 파일 디스크립터를 가지고 있는데, 나는 그것

0열

2답변

Apache kafka와 Angular.js의 통합

아파치 kafka에서 '샘플'주제를 만들고 제작자, 게시 된 메시지를 실행했습니다. 나는 게시 된 메시지를 볼 수있는 다른 터미널에서 소비자를 운영한다. 이제 Angularjs를 사용하여 Grid에서 messgaes를 표시하려고합니다. 메시지를 소비하고 테이블로 표시하는 방법이 있습니까?