apache-kafka

9Ciepło

2Odpowiedz

Różnice między przetwarzaniem strumienia a przetwarzaniem wiadomości

Jaka jest podstawowa różnica między przetwarzaniem strumienia a tradycyjnym przetwarzaniem komunikatów? Jak mówią ludzie, kafka jest dobrym wyborem do przetwarzania strumieniowego, ale w istocie kafka

stream queue rabbitmq apache-kafka messaging 2017-01-19

---

5Ciepło

3Odpowiedz

Kafka nie usuwając klucz z nagrobka

tworzę temat Kafka o właściwościach poniżej min.cleanable.dirty.ratio = 0,01, delete.retention.ms = 100, segment.ms = 100, cleanup.policy = kompaktowy Powiedzmy wstawić par kV w celu 1111: 1, 1111: 2,

apache-kafka confluent-kafka 2017-10-08

---

6Ciepło

1Odpowiedz

Jak wdrożyć testowanie kontraktowe, gdy kafka jest zaangażowany w architekturę mikroserwisu?

Obecnie pracuję nad projektem, w którym mamy wdrożenie kafka w architekturze mikro-usług. Czy udało Ci się stworzyć przypadki testowania kontraktów dla mS do interakcji z kafka przy użyciu pact-jvm? M

java jvm apache-kafka microservices pact 2017-07-03

---

6Ciepło

2Odpowiedz

Jak zaimplementować mikroserwisową architekturę opartą na zdarzeniach ze Spring Cloud Stream Kafka i baza danych dla usługi

Próbuję zaimplementować architekturę sterowaną zdarzeniami do obsługi transakcji rozproszonych. Każda usługa ma własną bazę danych i wykorzystuje Kafkę do wysyłania wiadomości w celu informowania inny

apache-kafka spring-cloud microservices spring-cloud-stream spring-kafka 2017-02-09

---

33Ciepło

1Odpowiedz

Czy istnieje jakikolwiek powód, aby używać RabbitMQ zamiast Kafki?

Zostałem poproszony o ocenę RabbitMQ zamiast Kafki, ale trudno było znaleźć powód, że robi coś lepszego niż Kafka. Czy ktokolwiek wie, czy jest naprawdę lepszy pod względem przepustowości, trwałości,

rabbitmq apache-kafka message-queue 2017-02-10

---

9Ciepło

2Odpowiedz

Spring Kafka asynchroniczne wysyłanie bloków blokowych

Używam Spring-Kafka w wersji 1.2.1, a gdy serwer Kafka jest wyłączony/nieosiągalny, asynchroniczne wysyłanie blokuje przez pewien czas. Wydaje się, że jest to limit czasu TCP. Kod jest coś takiego: Li

spring asynchronous apache-kafka send producer 2017-07-13

---

5Ciepło

1Odpowiedz

Metoda Kafka stream.allMetadata() zwraca pustą listę

Próbuję uzyskać interaktywne zapytania współpracujące ze strumieniami Kafki. Mam Zookeepera i Kafkę działającego lokalnie (w oknach). Gdzie używam C: \ temp jako folderu do przechowywania, zarówno dla

apache-kafka kafka-consumer-api kafka-producer-api apache-kafka-streams 2017-09-05

---

6Ciepło

1Odpowiedz

Dlaczego Kafka Direct Stream tworzy nowy dekoder dla każdej wiadomości?

Mam aplikację do przesyłania strumieniowego Spark napisaną w Javie i używanie Sparka 2.1. Używam KafkaUtils.createDirectStream do czytania wiadomości od Kafki. Używam kodera/dekodera kryo dla wiadomoś

java apache-spark apache-kafka spark-streaming kryo 2017-12-15

---

9Ciepło

1Odpowiedz

Iskrzenie strumieniowe z aktora

Chciałbym, aby aktor konsumencki zasubskrybował temat Kafki i przesyłał dane do dalszego przetwarzania za pomocą Spark Streaming poza konsumentem. Dlaczego aktor? Ponieważ przeczytałem, że jego strate

scala apache-kafka spark-streaming actor 2017-02-21

---

6Ciepło

1Odpowiedz

Kafka Producent NetworkException i Timeout wyjątkami

Jesteśmy coraz losowo NetworkExceptions i TimeoutExceptions w naszym środowisku produkcyjnym: Brokers: 3 Zookeepers: 3 Servers: 3 Kafka: 0.10.0.1 Zookeeeper: 3.4.3 Jesteśmy czasami uzyskiwanie t

java apache-kafka 2017-11-06

---