kafka-producer-api

7Ciepło

2Odpowiedz

Gwarantowana dostawa wielu wiadomości do klastra Kafka

Jeśli publikuję kilka wiadomości z rzędu do klastra Kafka (przy użyciu new Producer API), otrzymuję od producenta Future dla każdej wiadomości. Teraz, zakładając mam skonfigurowany mój producent mieć

8Ciepło

2Odpowiedz

Kafka rzuca java.nio.channels.ClosedChannelException

Kiedy próbuję zużywać wiadomości z serwera kafka, który jest hostowany w ec2 z narzędziem kafka konsoli (V 0.9.0.1, myślę, że to używa starych konsumenckich API) Dostaję następujący wyjątek . Jak mogę

6Ciepło

1Odpowiedz

Konwertowanie danych na generyczne zapisy w pliku confluent.io i przesyłanie za pośrednictwem produktu KafkaProducer

Jestem całkowicie nowym użytkownikiem Kafki i Avro i próbuję użyć pakietu konfluentującego. Mamy istniejące POJO, których używamy do JPA i chciałbym móc po prostu utworzyć instancję moich POJO bez kon

6Ciepło

1Odpowiedz

Producent Kafki nie jest w stanie aktualizować metadanych po pewnym czasie.

Mam środowisko kafka, które ma 3 brokers i 1 zookeeper. Przesłałem około 20K wiadomość w moim temacie. Apache Storm oblicza dane w temacie dodanym przez producenta. Po minęło kilka godzin, podczas gdy

5Ciepło

1Odpowiedz

Jak ustawić rozmiar wiadomości w Kafce?

Obecnie używam Kafki 0.9.0.1. Zgodnie z niektórymi źródłami, które znalazłem, sposobem na ustawienie rozmiarów komunikatów jest zmodyfikowanie następujących kluczowych wartości w server.properties. me

5Ciepło

1Odpowiedz

Metoda poll() Kafki Consumer zostaje zablokowana

Jestem nowicjuszem w Kafka 0.9 i testowaniem niektórych funkcji Zdałem sobie sprawę z dziwnego zachowania w implementowanym przez Java Konsumencie (KafkaConsumer). Broker Kafka znajduje się w zewnętrz

8Ciepło

1Odpowiedz

Konsument Kafki "nie udało się znaleźć lidera" podczas pobierania metadanych tematu

Kiedy próbuję użyć skryptu producenta i konsumenta (0.9.0) firmy Kafka do wysyłania/odbierania wiadomości z tematu, otrzymuję poniższe błędy. Producent Błąd [2016-01-13 02:49:40,078] ERROR Error when

5Ciepło

1Odpowiedz

Metoda Kafka stream.allMetadata() zwraca pustą listę

Próbuję uzyskać interaktywne zapytania współpracujące ze strumieniami Kafki. Mam Zookeepera i Kafkę działającego lokalnie (w oknach). Gdzie używam C: \ temp jako folderu do przechowywania, zarówno dla