kafka-consumer-api

2열

1답변

몇 시간 전에 내 서비스 중 하나가 작동을 멈췄습니다. 서버를 다시 시작했지만이 소비자 프로세스가 Kafka에 등록하지 않았습니다. 소비자가 시작될 때 표시되는 내용입니다. 2017-04-21 10:22:54.887 INFO 18036 --- [afka-consumer-1] o.a.k.c.c.internals.ConsumerCoordinator : Revo

0열

1답변

Kafka 소비자 API가 제대로 작동하지 않습니다.

카프카에 새로 입문했습니다. 카프카에서 일하기 시작했습니다. 아래 문제에 직면하고 있습니다. 문제를 해결할 수 있도록 도와주세요. 미리 감사드립니다. 먼저 제작자 API를 작성 중이지만 잘 작동하고 있지만 Consumer API 메시지는 표시되지 않습니다. 내 코드는 다음과 같다 : import java.util.Arrays; import java.uti

0열

1답변

kafka 소비자가 서버에서 레코드를 소비하지 않습니다

레코드를 소비하기 위해 java class을 만들었습니다. 해당 서버와 모든 작업이 연결되어 있습니다. 로컬 컴퓨터에서이 class을 실행하고 메시지를 소비 할 수 있지만 메이븐 빌드를 마친 후 항아리 파일, 거기에서 내 서버에이 항아리 파일을 배치 오전 내 java class, 거기에 메시지를받지 못하고 있지만 성공적으로 항목을 구독하고 있지만 로컬 구독

0열

1답변

camel-kafka에서 예외가 발생할 때 오프셋하지 않기

camel-kafka 구성 요소를 사용하고 있습니다. 엄격한 주문을해야하며 메시지 손실을 감당할 수 없습니다. 따라서 약간의 예외가있는 경우 오프셋을 적용하려고하지 않습니다. autoCommitEnable = false을 설정하고 예외를 처리하지 않습니다. 하지만 예외가 발생해도 예외가 발생합니다 (스택 트레이스 만 인쇄됩니다.) 이 시나리오를 처리하기 위

0열

1답변

카프카의 __consumer_offsets 관련 문제 0.10.2.0

단일 노드 카프카 설정이 있습니다. 그것은 잘 작동했다. 나는 다른 중개인을 추가하고 두 개의 노드가있는 카프카 클러스터를 만들었다. 저는 별도의 사육사를 설치하지 않고 카프카 패키지와 함께 제공되는 동일한 사육사를 사용합니다. 클러스터를 만들기 위해 나는 아래의 변경을했다. broker1.properties의 내용 : 두 번째 노드의 첫 번째 노드에서 b

2열

1답변

Apache Kafka : 주제에 메시지가 있는지 확인하십시오.

특정 메시지가 이미 주제에 존재하는지 여부를 확인해야하는 상황이 있습니다. 주제가 중복되지 않아도됩니다. 모든 메시지를 사용하고이를 확인하는 대신 모든 사람이이를 수행하는 모든 방법을 제안 할 수 있습니까?

0열

1답변

Kafka 소비자 API가 Java 클라이언트를 사용하여 구독하지 않습니다.

카프카 : 0.10.1.0 (클라이언트 & 서버) Java 클라이언트. 동물원 : 3.4.6 설정 : 제작자가 메시지를 게시합니다. 주제에 보낸 메시지는 구독이 작동하지 않는 동안 폴링 때 ./kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list localhost:9093 --topic TEST.TOPI

0열

1답변

kafka-0.9는 소비자 데이터가 아닙니다.

저는 소비자 데이터에 0.9 버전의 Kafka를 사용하지만, 프로그램은 항상 consumer.poll (100) 행으로 실행되고 계속 실행되지 않습니다. 나는 kafka-clients-0.9.0.0의 항아리를 사용합니다. 카프카 : kafka_2.10-0.9.0.0 사육사 : 사육사-3.4.5 public static void main(String[] ar

1열

2답변

카프카 소비자가 최신 메시지부터 시작하지 않음

화제의 최신 메시지에서 시작되는 카프카 소비자를 갖고 싶습니다. auto.offset.reset의 값이 최신이지만, 소비자 2 일 전에 속하는 형태로 메시지를 시작하고 다음을 잡는다 있지만 private static Properties properties = new Properties(); private static KafkaConsumer<String,

0열

1답변

Druid-Tranquility (수퍼 셋)를 사용하여 신분 데이터 카프카 채널을 읽는 방법은 무엇입니까?

우분투 서버에서 Divolte Collector를 설정하여 웹 사이트에서 클릭 스트림 데이터를 수집합니다. 데이터는 divolte-data라는 Kafka 채널에 기록됩니다. 그럼 난 druid.io (스파크를 읽을 수있는)를 포함하여 일반적인 데이터베이스에 여러 커넥터가 에어 비앤비 상위 집합으로 데이터를 시각화하고 싶은 V0:j2ive5p1:QHQbOui