apache-kafka

5Ciepło

1Odpowiedz

Apache Spark-Kafka.TaskCompletionListenerException & KafkaRDD $ KafkaRDDIterator.close NPE w klastrze lokalnym (tryb klienta)

Mój kod strumieniowania iskry działa bezproblemowo w środowisku IDE Eclipse. Ale po uruchomieniu go w lokalnym klastrze iskier daje org.apache.spark.util.TaskCompletionListenerException. Również kod "

8Ciepło

2Odpowiedz

producent kafka rzuca EOFException podczas pracy

Używam Kafki 0.8.2.1 i API nowego producenta. Serwer jest skonfigurowany jako pojedynczy węzeł w sieci lokalnej. Problem polega na tym, że producent rzuca EOFException po uruchomieniu przez pewien cza

20Ciepło

3Odpowiedz

Jak korzystać z wielu klientów w Kafce?

Jestem nowym studentem studiującym Kafkę i natknąłem się na pewne zasadnicze problemy, które polegały na zrozumieniu wielu konsumentów, że artykuły, dokumentacje itp. Nie były dotychczas zbyt pomocne.

6Ciepło

1Odpowiedz

spring-integration-kafka konfiguracja klienta, aby otrzymać wiadomość od określenia partycji

Zacząłem używać w moim projekcie spring-integration-kafka i mogę produkować i konsumować wiadomości od Kafki. Ale teraz chcę utworzyć komunikat do określonej partycji, a także pobrać wiadomość z okreś

16Ciepło

1Odpowiedz

Apache Kafka z Avro i Schema Repo - gdzie w wiadomości pojawia się schemat Id?

Chcę użyć Avro do serializowania danych dla moich wiadomości Kafka i chciałbym użyć go z repozytorium schematów Avro, więc nie muszę dołączać schematu do każdej wiadomości. Używanie Avro z Kafką wydaj

5Ciepło

1Odpowiedz

Jak mogę tworzyć wiadomości za pomocą API Kafka 8.2 w Javie?

Próbuję pracować z interfejsem kafka API w języku Java. Używam następującej zależności: <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> <version>

9Ciepło

3Odpowiedz

Nie można uruchomić serwera Zookeepera - Kafka Setup

Próbuję skonfigurować Kafkę, nawiązując do przewodnika szybkiego startu na stronie kafejki apache i podczas uruchamiania serwera zookeeper utknie na tym etapie ... Byłbym wdzięczny, gdyby ktoś mógł po

14Ciepło

2Odpowiedz

Jak mogę z wdziękiem poradzić sobie z awarią Kafki?

Łączę się z Kafką przy użyciu biblioteki klientów kafli 0.8.2.1. Mogę z powodzeniem łączyć się z Kafką, ale chcę z wdziękiem poradzić sobie z upadkiem Kafki. Oto moja konfiguracja: kafkaProperties.set

5Ciepło

2Odpowiedz

Jak zbudować skuteczną kontrolę zdrowia brokera Kafki?

W mojej aplikacji wykonam pewnego rodzaju kontrolę stanu mojego kufrowskiego kufra. Obecnie robię TopicMetadataRequest do wykrywania martwych brokerów: Future { // this will fail if Kafka is unav

31Ciepło

4Odpowiedz

Kafka - pobieranie metadanych dla tematów nie powiodło się

Próbuję napisać klienta Java dla serwerów Kafka i ZooKeeper firm trzecich. Potrafię wymieniać i opisywać tematy, ale kiedy spróbuję je przeczytać, powstaje ClosedChannelException. Reprodukuję je tutaj