kafka-consumer-api

1열

1답변

Spring JDBC - 카프카 소비자를위한 회수 가능한 예외

카프카 주제에서 메시지를 읽으려면 스프링 카프카 소비자를 사용하고 있습니다. 나는 Oracle DB에서이를 유지하고 있습니다. DB 연결 오류가있을 때마다 재 시도를 수행하려고합니다. Oracle JDBC에 연결하기 위해 Spring JDBC를 사용하고 있습니다. JDBC 연결 문제 만 재 시도해야하는 경우 추가해야하는 예외 클래스 목록은 무엇입니까? /*

java spring spring-jdbc kafka-consumer-api spring-kafka 2017-10-04

---

0열

1답변

기본 및 우선 순위 큐용 카프카에서 데이터 정렬

제품 ID를 순서대로 처리해야하며 kafka 또는 내 코드에서 데이터가 손실되는 경우이를 대비하여 kafka를 사용할 계획입니다.이 제품 ID를 모두 가지고 있습니다. 레코드가 주어진 시간에 처리되지 않으면 데이터베이스가 될 수 있습니다. 24 시간이 필요합니다. 큐에서 데이터를 다시 게시해야하지만 kafka에는 우선 순위 개념이 없습니다. 우선 순위 큐로

java apache-kafka kafka-consumer-api apache-kafka-connect 2017-10-05

---

1열

1답변

Kafka 소비자 - 복구 방법에서 청취자가 수신 한 매개 변수를 가져옵니다.

봄 카프카 소비자를 구축 중입니다. 나는 재시도 메커니즘을 설정했다. 재시도가 끝나면 실패한 메시지를 불필요한 편지 주제로 푸시하고 싶습니다. 는이 방법은 아래의 매개 변수 public void listen(@Payload Map<String, Object> conciseMap, @Header(KafkaHeaders.RECEIVED_PARTITI

spring spring-boot kafka-consumer-api kafka-producer-api spring-kafka 2017-10-05

---

0열

1답변

Apache kafka - 소비자 지연 옵션

작은 지연으로 특정 주제에 대해 kafka에서 소비자를 시작하고 싶습니다. 자세히 말하면, 소비자가 메시지를 생성 한 후 특정 시간 지연 후에 주제에서 메시지를 소비하기를 원합니다. 누구나 kafka에 속성이나 옵션을 사용 가능하게 설정한다고 말할 수 있습니까? 미리 감사드립니다.

apache-kafka kafka-consumer-api 2017-10-10

---

1열

2답변

Kafka에서 잘못된 시간을 읽는 StreamSets 데이터 수집기 ​​

StreamSets 데이터 수집기가 잘못된 datetime 값을 읽는 것 같습니다. Confluent에서 간단한 주제를 읽었습니다 : Landoop Kafka 항목으로 밀리 초 단위로 날짜/시간 값을 확인할 때 올바른 datetime을 표시하지만 StreamSet에서 Kafka Consumer 0.10.0.0으로 읽을 때 - 날짜 시간은 3 시간입니다. 그

timezone kafka-consumer-api confluent streamsets 2017-10-16

---

0열

1답변

Kafka Consumer : onPartitionsRevoked 및 onPartitionsAssigned 콜백을 하나의 poll() 호출에서 실행할 수 있습니까?

카프카 소비자 API 0.10.2.1을 사용하고 있습니다. KafkaConsumer 파티션 지정 및 취소에 대한 콜백을 제공 public void onPartitionsRevoked(Collection<TopicPartition> partitions); public void onPartitionsAssigned(Collection<TopicPartitio

java apache-kafka kafka-consumer-api 2017-10-18

---

0열

1답변

카프카 브로커에 연결하는 데 문제가 있습니다.

스프링 카프카 클라이언트를 사용하여 카프카 서버에 연결하려고합니다. & 로그에 아래 오류가 있습니다. 내가 확인한 특정 kafka 브로커 IP에 연결 중입니다. 아래 오류 로그에 로컬 참조가 표시됩니다. 이 문제를 더 자세히 디버깅하도록 도와 주시겠습니까? logback.xml을 사용하여 푸시 중입니다. 아래는 구성입니다. 테스트 전에 kafka 호스트와

java spring apache-kafka kafka-consumer-api spring-kafka 2017-10-18

---

0열

1답변

4 개의 파티션이있는 단일 제작자를위한 여러 소비자 설정 Kafka Java

4 개의 파티션으로 구성된 간단한 제작자를 만들었으며 소비자 그룹에 4 명의 소비자를 생성하여 각 파티션의 데이터를 소비하려고합니다. 어떻게하면됩니까? 소비자 코드 코드 public class KafkaConsumer { static List<String> list = new ArrayList<String>(); public static

java apache-kafka kafka-consumer-api 2017-10-20

---

0열

1답변

일대 다 KStream-KStream 조인

두 개의 카프카 KStream간에 일대일 조인을 수행하는 방법은 무엇입니까? 아래 코드는 일대일 방식으로 두 개의 Kafka KStream을 조인합니다. 누군가 KStream과의 일 대 다수 참여를 수행하는 방법을 안내 할 수 있습니까? 주제에 수신 된 데이터는 generics입니다. < String, JsonNode> 주제에 쓰여지는 데이터의 형식은 입니

java kafka-consumer-api apache-kafka-streams 2017-10-25

---

1열

2답변

10 초 삭제 후 카프카 주제가 다시 나타납니다.

카프카 주제 삭제 문제가 있습니다. 주제를 생성/삭제하고 메시지를 소비하는 &을 생성하기 위해 kafka rest API를 사용합니다. 주제가 삭제 될 주제를 삭제하려고 시도했으나 10 초 후에 주제가 다시 나타납니다. 소비자 그룹 오프셋을 검사했고 LAG가 음수로 나열되었습니다. 고정 표시기 실행 --net = --rm confluentinc/CP-카프카

apache-kafka kafka-consumer-api 2017-10-26

---