Pytania otagowane jako apache-kafka

Apache Kafka to rozproszona platforma przesyłania strumieniowego zaprojektowana do przechowywania i przetwarzania strumieni danych o dużej przepustowości.

13
Czy istnieje sposób na usunięcie wszystkich danych z tematu lub usunięcie tematu przed każdym uruchomieniem?
Czy istnieje sposób na usunięcie wszystkich danych z tematu lub usunięcie tematu przed każdym uruchomieniem? Czy mogę zmodyfikować plik KafkaConfig.scala, aby zmienić logRetentionHourswłaściwość? Czy istnieje sposób, w jaki wiadomości są usuwane, gdy tylko konsument je przeczyta? Używam producentów do pobierania danych skądś i wysyłania danych do określonego tematu, w którym …
2
Różnica między Redis i Kafka [zamknięte]
Zamknięte . To pytanie musi być bardziej skoncentrowane . Obecnie nie przyjmuje odpowiedzi. Chcesz poprawić to pytanie? Zaktualizuj pytanie, aby skupiało się tylko na jednym problemie, edytując ten post . Zamknięte 2 miesiące temu . Popraw to pytanie Redis może być używany jako subwoofer w czasie rzeczywistym, tak jak Kafka. …
5
Oblicz średnią prędkość dróg [zamknięte]
Zamknięte . To pytanie musi być bardziej skoncentrowane . Obecnie nie przyjmuje odpowiedzi. Chcesz poprawić to pytanie? Zaktualizuj pytanie, aby skupiało się tylko na jednym problemie, edytując ten post . Zamknięte 3 dni temu . Poszedłem na rozmowę o pracę inżyniera danych. Ankieter zadał mi pytanie. Dał mi pewną sytuację …
2
Użyj ponownie tego samego komunikatu, jeśli przetwarzanie komunikatu nie powiedzie się
Używam klienta Confluent.Kafka .NET w wersji 1.3.0. Postępuję zgodnie z dokumentami : var consumerConfig = new ConsumerConfig { BootstrapServers = "server1, server2", AutoOffsetReset = AutoOffsetReset.Earliest, EnableAutoCommit = true, EnableAutoOffsetStore = false, GroupId = this.groupId, SecurityProtocol = SecurityProtocol.SaslPlaintext, SaslMechanism = SaslMechanism.Plain, SaslUsername = this.kafkaUsername, SaslPassword = this.kafkaPassword, }; using (var consumer …
2
Kafka: Ciągle otrzymuję FETCH_SESSION_ID_NOT_FOUND
Ciągle otrzymuję FETCH_SESSION_ID_NOT_FOUND. Nie jestem pewien, dlaczego tak się dzieje. Czy ktoś może mi się tutaj podobać, na czym polega problem i jaki będzie wpływ na konsumentów i brokerów. Dziennik serwera Kafka: INFO [2019-10-18 12:09:00,709] [ReplicaFetcherThread-1-8][] org.apache.kafka.clients.FetchSessionHandler - [ReplicaFetcher replicaId=6, leaderId=8, fetcherId=1] Node 8 was unable to process the fetch …
Korzystając z naszej strony potwierdzasz, że przeczytałeś(-aś) i rozumiesz nasze zasady używania plików cookie i zasady ochrony prywatności.
Licensed under cc by-sa 3.0 with attribution required.