it-swarm-eu.dev

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?

Kafka z klientem .Net

Jak mogę uzyskać NAJNOWSZE przesunięcie tematu kafki?

jak nazwa grupy dla wiadomości w kafce przy użyciu wiersza

Kafka Getting error Brak rozpoznawalnych adresów startowych bootstrap podanych w serwerach ładowania początkowego

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ę

Kafka lista klientów

Kafka w Dockerze nie działa

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)

Apache Camel vs Apache Kafka

Ścieżka klasy jest pusta. Najpierw utwórz projekt, np. uruchamiając './gradlew jar -PscalaVersion = 2.11.12'

Jak uzyskać dane ze starego punktu przesunięcia w Kafce?

Czy istnieje sposób na usunięcie wszystkich danych z tematu lub usunięcie tematu przed każdym uruchomieniem?

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

Apache Kafka vs Apache Storm

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

Usuń temat w Kafka 0.8.1.1

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

Fluentd vs Kafka

kafka się liczyć na temat

Temat Kafka dla konkretnego rekordu

Lider niedostępny Kafka w Console Producer

Włącz JMX w Kafka Brokers

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

Dlaczego nie mogę zwiększyć sesji. Timeout.ms?

BŁĄD Błąd podczas wysyłania wiadomości do tematu