apache-kafka

6Ciepło

2Odpowiedz

Ponowne równoważenie topologii burzy za pomocą kodu Java

Próbuję ponownie zrównoważyć moją topologię Storm, która używa KafkaSpout. Mój kod to: TopologyBuilder builder = new TopologyBuilder(); Properties kafkaProps = new Properties(); kafkaProps.p

5Ciepło

7Odpowiedz

gdzie mogę znaleźć repozytorium maven dla kafka?

Chcę wypróbować kafka 0.8 (jak rozumiem, jest już wydana). Ale gdzie mogę znaleźć repozytorium kafka maven. A jaki dodatkowy URL do repozytorium powinienem dodać? Znalazłem kilka blogów z <dependency>

6Ciepło

2Odpowiedz

Jak zdobyć potwierdzenie od Kafki

Jak otrzymać potwierdzenie od Kafki, gdy wiadomość zostanie zużyta lub przetworzona. Czy może brzmieć głupio, ale czy istnieje sposób na poznanie początkowego i końcowego przesunięcia tego komunikatu,

5Ciepło

2Odpowiedz

Apache Kafka Grupa konsumentów i prosty konsument

Jestem nowy w Kafce, co zrozumiałem sofar dotyczące konsumenta jest zasadniczo dwa rodzaje realizacji. 1) The High level consumer/consumer group 2) Simple Consumer Najważniejszą częścią o wysokim pozi

5Ciepło

1Odpowiedz

Partition re-balance na pośredników w Kafka 0,8

Stosunkowo uboga dokumentacja Kafki 0,8 nie wspomina co oczekiwane zachowanie do wyważania istniejących tematów, partycje i repliki na maklerów jest. Dokładniej, co jest oczekiwane zachowanie na przyb

12Ciepło

2Odpowiedz

Kafka 0.8, czy można utworzyć temat z partycją i replikacją za pomocą kodu java?

W Kafki 0.8beta tematem mogą być tworzone za pomocą polecenia jak poniżej wymienione here bin/kafka-create-topic.sh --zookeeper localhost:2181 --replica 2 --partition 3 --topic test powyższe polecen

10Ciepło

1Odpowiedz

Wiele wylewek Storm-Kafka, jak podzielić ładunek?

Próbuję udostępnić zadanie wśród wielu wylewek. Mam sytuacji, gdzie dostaję jeden krotki/wiadomości naraz ze źródła zewnętrznego i chcę mieć wiele wystąpień dziobek główną intencją jest dzielenie obci

6Ciepło

2Odpowiedz

Kafka Serializacja obiektu

Zacząłem grać z Kafką. Ustawiłem konfigurację zookeepera i udało mi się wysłać i zużyć ciągi wiadomości. Teraz próbuję przekazać obiekt (w java), ale z jakiegoś powodu podczas analizowania wiadomości

5Ciepło

1Odpowiedz

kafka nie można podłączyć do zookeepera - FATAL Błąd krytyczny podczas uruchamiania KafkaServerStable

Cóż ... każda usługa na świecie może połączyć się z moim zookeeper oczekiwać kafka. Poniżej jest mój ciąg połączenia w server.properties złożyć zk.connect=1.dzk.syd.druid.neo.com:2181, 2.dzk.syd.druid