reactive-kafka

2열

1답변

Bytestring을 소스로 변환하는 방법 [Bytestring, Any]

Kafka Reactive Streams 소비자의 Bytestring 파일을 수신하고 있습니다. 이 Bytestring과 함께 akka-http 요청을 HttpEntity.Default 엔터티로 생성하려고합니다. HttpEntity.Default는 Source [Bytestring, Any]를 매개 변수 중 하나로 요구합니다. 둘을 연결하는 가장 좋은 방법

scala akka-stream akka-http reactive-kafka 2016-09-29

---

0열

1답변

Akka Streams 카프카 프로듀서를 병렬로 사용하기

카프카에 쓰기를 병렬 처리하고 싶습니다. 카프카에 데이터를 보내는 여러 제작자가 있습니다. 다른 내 스트림에는 소스의 여러 초기 단계가 있고 데이터를 전송할 때 16 명의 직원이 동시에 데이터를 보내고 싶습니다. Akka Streams Kafka를 akka-stream Graph DSL에 임베딩해야하고 밸런서를 사용하거나 더 쉬운 솔루션이 필요한지 궁금합니

akka-stream reactive-kafka 2017-09-13

---

0열

1답변

Akka-Stream을 사용하여 Reactive Kafka에서 대형 메시지를 청크 및 재조합하는 방법

Kafka를 사용하여 큰 파일을 전송할 때이를 파티션간에 배포 한 다음 Akka-Stream을 사용하여 다시 조합 할 수 있습니까? case class LargeMessage(bytes : Seq[Byte], topic : String) def messageToKafka(message : LargeMessage, maxMessageSize : Int)

scala apache-kafka akka-stream reactive-kafka 2016-09-30

---

0열

2답변

찾을 수 java.util.concurrent.Future 필수 scala.concurrent.Future

관련 : 나는 AKKA의 HTTP 응용 프로그램이 How to integrate akka streams kafka (reactive-kafka) into akka http application? , 나는 ': scala.concurrent.Future wrapper for java.util.concurrent.Future 이 내 다른 질문에서 온 다음과 같

scala apache-kafka akka akka-http reactive-kafka 2017-09-18

---

0열

1답변

Akka Streams Kafka에서 ProducerMessage를 구성하는 동안 오프셋 매개 변수를 구성하는 방법은 무엇입니까?

Scala 2.11 및 Akka Streams Kafka 0.17을 사용하고 있습니다. 가 Source이 Source.actorRef를 사용하여 만들어집니다 : 은 내가 스트림 있습니다. 여기에서는 액터가 일정한 간격으로 실행되고 메시지를 연속적으로 생성하도록 예정되어 있으며 스트림으로 출력됩니다. Producer을 Flow으로 첨부했습니다. 생산자가 Pr

scala apache-kafka akka-stream reactive-kafka 2017-11-11

---

0열

1답변

게시자를 사용하여 메시지를 생성하는 방법 (reactive-kafka에서)?

나는 반응성 카프카 모듈에서 코드와 함께 일해야 : val kafka = new ReactiveKafka() val kafkaIdpsMsgs: Publisher[StringKafkaMessage] = kafka.consume( ConsumerProperties( brokerList = kafkaHosts, zooKeeperH

scala apache-kafka reactive-kafka 2016-08-23

---

0열

1답변

reactive-kafka : 게시자가 소비자와 함께하는 이유는 무엇입니까?

나는 다음과 같은 문서를 보았다 : https://github.com/akka/reactive-kafka와 나는 다음과 같은 코드 보았다 implicit val actorSystem = ActorSystem("ReactiveKafka") implicit val materializer = ActorMaterializer() val kafka = new

apache-kafka reactive-kafka 2016-08-28

---

0열

1답변

새로 만든 주제를 반응 카프카의 서브 스크립 션에 추가합니다

iam은 우리의 놀이 스칼라 프로젝트에서 반응 카프카를 개발했습니다. 우리는 소비자 그룹과 일하는 사람들이 구독하는 5 개의 주제를 만든 프로젝트에서 새로운 주제를 만들었습니다. 나는 기존의 소비자 그룹 (가능하다) 내 코드는이 항목을 추가 할 수 있습니다 : val consumerSettings = ConsumerSettings(system, new By

akka reactive-kafka 2017-03-22

---

0열

1답변

Reactive Kafka : 존재하지 않는 주제에 대한 스트림을 만드는 중 오류가 없습니다.

최근 Reactive Kafka로 전환했습니다. 화제를 위해 시내를 창조하고있는 동안 화제가 존재하면 kafka는 어떤 과실도 던지지 않는다는 것을 보인다. 왜 그래야만하지? 주제의 존재를 명시 적으로 확인할 수있는 것은 AdminUtils.topicExists(zkClient, topicName)입니다. 스트림을 만들기 전에 주제가 독자적으로 존재하는지

apache-kafka reactive-kafka 2017-05-11

---

2열

2답변

Reactive-Kafka : 예외적으로 소비자를 일시 중지하고 요청시 다시 시도하는 방법

Google 그룹에 이미 this 질문을했지만 아직 응답을받지 못했습니다. 다른 잠재 고객을 위해 여기에 게시하십시오. 우리는 Reactive-Kafka를 사용하고 있습니다. 다음과 같은 시나리오가 있습니다. 메시지를 처리하는 동안 예외가 발생하면 소비자에게 메시지를 보내지 않습니다. 메시지는 규정 된 시간 이후에 또는 소비자 측의 명시 적 요청 후에 재

scala akka-stream reactive-kafka 2017-02-03

---