apache-kafka

5Ciepło

1Odpowiedz

Nie Serializable wyjątek podczas czytania Kafka nagrywa z Spark Streaming

Kiedy strumieniowe z Kafki użyciu Spark 2.0, otrzymuję następujący błąd: org.apache.spark.SparkException: Job aborted due to stage failure: Task 0.0 in stage 1.0 (TID 1) had a not serializable resul

apache-spark apache-kafka spark-streaming 2016-09-03

---

8Ciepło

2Odpowiedz

Przesunięcia przechowywane w Zookeeperze lub Kafce?

Jestem nieco zdezorientowany tym, gdzie są zachowane przesunięcia podczas używania Kafki i Zookeepera. Wygląda na to, że przesunięcia w niektórych przypadkach są przechowywane w Zookeeperze, w innych

node.js apache-kafka apache-zookeeper 2016-12-14

---

6Ciepło

2Odpowiedz

Wyślij do klienta Java Objects Kafka Temat

Mam niestandardowego obiektu Java i chcą wykorzystać JVM jest w wybudowanym serializacji, aby wysłać go do tematu Kafki, ale nie serializacji z błędem poniżej org.apache.kafka. common.errors.Serializa

java serialization apache-kafka 2016-12-14

---

5Ciepło

1Odpowiedz

Spark: 2.0.2 java.util.ConcurrentModificationException: KafkaConsumer nie jest bezpieczne dla wielowątkowych dostępu

otrzymuję poniżej błędu z Kafki 0.10.1.0 i iskra 2.0.2 private val spark = SparkSession.builder() .master("local[*]") .appName(job.name) .config("spark.cassandra.connection.host","localhost")) .co

apache-spark apache-kafka spark-streaming 2016-12-20

---

5Ciepło

2Odpowiedz

Jaki jest najlepszy sposób przekazywania wiadomości kafka z moich węzłów brzegowych?

Mam pracownika w regionie głównym (USA-Wschód), który oblicza dane o ruchu w naszych lokalizacjach brzegowych. Chcę przenieść dane z regionu brzegowego do naszego głównego regionu kafka. Przykładem je

go apache-kafka regional 2016-11-02

---

5Ciepło

1Odpowiedz

Kafka Consumer otrzymaj parę wartości klucza

Obecnie pracuję z Kafka i Flink, mam kafka działającego na moim lokalnym komputerze i stworzyłem temat, który jest konsumowany. Pulpit \ Kafka \ bin \ WINDOWS> Kafka-console-consumer.bat --zookeeper l

apache-kafka kafka-consumer-api 2016-12-30

---

6Ciepło

3Odpowiedz

Jak ładuje się saldo kafka?

Napotkałem pytanie z równoważeniem obciążenia w kafejce. Stworzyłem więc temat z 10 partycjami i utworzyłem 2 klientów. Dziesięć partycji zostało podzielonych i przypisanych do tych konsumentów (5 par

java performance apache-kafka load-balancing partition 2016-11-11

---

8Ciepło

1Odpowiedz

Confluent Platform vs Apache kafka

Jestem nowy w kafka. I ciekawy temat zlewni platformy. Wygląda na to, że użytkownicy nie mają zbyt dużej liczby użytkowników. Czy ciekła platforma daje znacznie więcej korzyści niż kafka? Czy ktoś moż

apache-kafka platform confluent 2016-09-26

---

5Ciepło

1Odpowiedz

Wiosenna integracja Kafka Odbiornik konsumentów nie Odbiera wiadomości

Zgodnie z dostarczoną dokumentacją here, próbuję na POC, aby uzyskać wiadomości do odbiornika, jak wspomniano w same documentation, Poniżej opisano, jak napisałem konfigurację. @Configuration public

java spring spring-integration apache-kafka 2016-10-06

---

11Ciepło

2Odpowiedz

Jak pobrać identyfikator przesunięcia podczas konsumpcji Kafki ze Sparka, zapisać w Cassandrze i użyć jej do ponownego uruchomienia Kafki?

Używam Sparka do konsumpcji danych z Kafki i zapisania go w Cassandrze. Mój program jest napisany w Javie. Używam biblioteki lib spark-streaming-kafka_2.10:1.6.2, aby to osiągnąć. Mój kod to: SparkCon

java apache-spark cassandra apache-kafka 2016-08-26

---