apache-kafka
Kafka Consumer - Zachowanie ankiety
Kafka: Interfejs API dla konsumentów a interfejs API dla strumieni
Czy Kafka obsługuje wiadomości z żądaniem odpowiedzi
Jak tworzyć tematy w kafejce Apache?
Kafka rzuca wyjątek Java.nio.channels.ClosedChannelException
Spring Boot Kafka: Nie można uruchomić konsumenta z powodu NoSuchBeanDefinitionException
Zrozumienie Kafka Tematy i partycje
Jak napisać plik do Kafka Producent
Błąd podczas publikowania wiadomości do tematu Kafki
Ogranicz rozmiar partii Kafka podczas korzystania ze Spark Streaming
Kafka - Ten serwer nie jest liderem tej partycji tematycznej
Tryb rozproszony Kafka Connect Koordynator grupy nie jest dostępny
Obsługa złych wiadomości za pomocą interfejsu API strumieni Kafki
Błąd podczas tworzenia tematu Kafki: - współczynnik replikacji większy niż dostępnych brokerów
Jak odczytywać dane przy użyciu Kafka Consumer API od samego początku?
Kafka - opóźniona implementacja kolejki przy użyciu wysokiego poziomu konsumenta
Pobierz ostatnią wiadomość ze skryptu konsoli konsumenckiej kafka
Kafka jak czytać z tematu __consumer_offsets
Konsument nie odbiera wiadomości, konsola kafka, nowa api konsumencka, Kafka 0.9
Czy wielu konsumentów Kafki może czytać tę samą wiadomość z partycji
Kafka Consumer Oznaczenie koordynatora 2147483647 martwych
Jak skonfigurować logowanie dla producentów Kafki?
Jak sprawdzić, czy serwer Kafka działa?
Jak mogę uzyskać NAJNOWSZE przesunięcie tematu kafki?
jak nazwa grupy dla wiadomości w kafce przy użyciu wiersza
zrozumienie identyfikatora grupy konsumentów
Kafka bootstrap-servers vs zookeeper w kafka-console-consumer
Liczenie Liczba wiadomości przechowywanych w temacie kafki
Nie jest jasne co do znaczenia auto.offset.reset i enable.auto.commit w Kafka
W jaki sposób Kafka przechowuje offset dla każdego tematu?
Jak potwierdzić bieżący offset wiosną kafka dla ręcznego zatwierdzenia
Spring Kafka Producer nie wysyła do Kafki 1.0.0 (Magic v1 nie obsługuje nagłówków rekordów)
Jak pisać konsumenci Kafki - jednowątkowe vs wielowątkowe
Brokerzy Leader bez pasującego błędu słuchacza w kafce
Czy klucz jest wymagany w ramach wysyłania wiadomości do Kafki?
Prosty osadzony Kafka ze startem wiosennym)
Kafka Pobieranie metadanych przez konsumentów dla tematów nie powiodło się
Co oznacza „Rebalancing” w Apache Kafka?
Spark Streaming - czytaj i pisz na Kafka
Różnica między session.timeout.ms a max.poll.interval.ms dla Kafka 0.10.0.0 i nowsze wersje
Kafka Klient otrzymuje parę klucz-wartość
Kafka Domyślny identyfikator grupy klienta
Jaka jest różnica między kafka najwcześniejsze i najnowsze wartości przesunięcia)
Jak uzyskać dane ze starego punktu przesunięcia w Kafce?
Problem równoważenia podczas czytania wiadomości w Kafce
Czy istnieje łatwy sposób instalacji Kafki w systemie Windows?
Uruchamianie w LeaderNotAvailableException podczas używania Kafki 0.8.1 z Zookeeperem 3.4.6
Błąd Apache Kafka w systemie Windows - nie można znaleźć lub załadować głównej klasy QuorumPeerMain
Nie znaleziono klasy KafkaUtils w streamingu Spark
Dlaczego konsumenci Kafki łączą się z opiekunem, a producenci otrzymują metadane od brokerów?
Kafka nie może połączyć się z Zookeeperem
Kafka na wielu węzłach Kubernetesa
Błąd podczas uruchamiania Kafki w systemie Windows
Spark Streaming + Kafka: SparkException: Nie można znaleźć przesunięć liderów dla zestawu
błąd podczas uruchamiania brokera kafka
Jak usunąć grupę klientów Kafka, aby zresetować przesunięcia?
Lista wszystkich tematów kafka
Kafka 1.0 zatrzymuje się z błędem FATAL SHUTDOWN. Katalog dzienników nie powiódł się
Kafka + Zookeeper: Nie można ustanowić połączenia z węzłem -1. Broker może nie być dostępny
Kopia zapasowa/przywracanie kafki i strażnika zooke
Integracja strumieniowania strukturalnego Spark z rejestrem Confluent Schema
Jak poprawnie zrestartować serwer kafka?
Jak sprawdzić, czy ZooKeeper jest uruchomiony czy uruchomiony z wiersza poleceń?
Czy Zookeeper jest koniecznością dla Kafki?
zookeeper nie jest rozpoznawaną opcją podczas wykonywania kafka-console-consumer.sh
Jakie są zalety i wady Kafka w porównaniu z Apache Pulsar
Kafka Uwierzytelnianie zookeepera SASL
Jak przygotować dane do formatu LibSVM z DataFrame?
Błąd enkodera podczas próby odwzorowania wiersza ramki danych na zaktualizowany wiersz
Jak możemy stworzyć temat w Kafce z IDE podobny API
Przykładowy błąd Apache Kafka: nie można wysłać wiadomości po 3 próbach
Jak uzyskać listę tematów z serwera kafka w Javie
kafka-server-stop.sh nie działa, gdy Kafka zaczął od skryptu Pythona
W Apache Kafka, dlaczego nie może być więcej instancji konsumenckich niż partycji?
Dlaczego nie mogę połączyć się z Kafką z zewnątrz?
Jak znaleźć wersję kafki w Linuksie
Jak wybrać rozmiar Kafki Cluster
Kafka - Nie można wysłać wiadomości do zdalnego serwera za pomocą Java
Java, Jak uzyskać liczbę wiadomości w temacie w kafejce Apache
Kafka QuickStart, advertised.Host.name daje kafka.common.LeaderNotAvailableException
Błąd podczas tworzenia tematów Kafka - współczynnik replikacji większy niż dostępnych brokerów
Temat Kafka dla konkretnego rekordu
Lider niedostępny Kafka w Console Producer
Kafka Nierozpoznany VM opcja „PrintGCDateStamps”
Jak zmienić liczbę replik tematu Kafki?
Błąd: Nie można znaleźć lub załadować głównej klasy config.zookeeper.properties