5Ciepło
1Odpowiedz
Przesunięcia konsumenta Kafki poza zasięgiem bez skonfigurowanej zasady resetowania dla partycji
5Ciepło
2Odpowiedz
KafkaConsumer 0.10 Komunikat o błędzie Java API: Brak bieżącego przypisania partycji
7Ciepło
2Odpowiedz
SBT nie może importować Kafka klasy koder/dekoder
8Ciepło
2Odpowiedz
Kafka rzuca java.nio.channels.ClosedChannelException
5Ciepło
1Odpowiedz
Czy możliwe jest uzyskanie określonego przesunięcia komunikatu w Kafce + SparkStreaming?
8Ciepło
2Odpowiedz
5Ciepło
1Odpowiedz
Metoda poll() Kafki Consumer zostaje zablokowana
5Ciepło
1Odpowiedz
Kafka Consumer otrzymaj parę wartości klucza
5Ciepło
1Odpowiedz
Metoda Kafka stream.allMetadata() zwraca pustą listę
7Ciepło
1Odpowiedz
Kafka Avro Consumer z problemami dekodera