我正在尝试设计一个Akka Stream，使用Alpakka来读取kafka主题中的事件，并将它们放到Couchbase中。stream logging")
.runWith(Sink.seq) 我所谓“不知何故”的意思是，这个流实际上是从主题中读取事件，并将它们作为json文档放到Couchbase中，尽管我不知道如何将消费者偏移量提交给如果我已经清楚地理解
浏览 21提问于2019-10-18得票数 0
我想在Couchbase中插入/更新文档，它应该自动插入/更新到neo4j数据库中。他们有没有插件或软件来做同样的事情？如何实现此功能？Couchbase企业版: 6.6 Neo4j企业版: 4.1.3 我读了这个博客https://dzone.com/articles/couchbase-amp-jdbc-integrations-for-neo4j
浏览 26提问于2020-11-24得票数 0
回答已采纳
TLDR:
我有一个简单的scala应用程序，它有一个Akka参与者，它使用来自Kafka主题的消息，如果在消息处理过程中出现异常，则将消息生成到相同的主题，Kafka客户端正在提交最新产生的消息的偏移量，就好像它已经被消耗了一样。" %% &quo
浏览 9提问于2022-01-30得票数 2
回答已采纳
2回答
是否可以由Kafka Producer对象发送字符串数组。我想从“topic1”文本中获取一些信息，然后将其分割成单个单词，并将其发送到另一个主题。valueDeserializer = new StringDeserializer) .withGroupId("kafka-sample")
.withProperty(ConsumerConfig.AUTO_OFFSET_R
浏览 1提问于2017-07-28得票数 0
回答已采纳
2回答
initialize(topic, consGroup, STREAMSERDE.STRINGDESER, STREAMSERDE.JSONDESER, props); logger.debug("record.offset() = " + record.offset() + " :
浏览 1提问于2019-01-22得票数 0
1回答
我是新使用akka streams kafka (和akka streams一般)。我正在尝试构建一个图表，以便将消息发布到不同的主题。如何将生产者作为流进行连接，以便提交已处理的消息？我试过使用Producer.flow，但我无法获取commitScaladsl import akka.kafka.ProducerMessage.Messageimplicit
浏览 12提问于2017-08-14得票数 0
回答已采纳
Kafka在0.10版本推出了Stream API，提供了对存储在Kafka内的数据进行流式处理和分析的能力。小白一名，各位大佬能给我解释一下流式计算、Kafka Streams的特点和架构吗？谢谢！
浏览 2159提问于2018-09-14
MSK集群-10个主题-每个=> 400总领先分区40个分区
为了在系统中实现高吞吐量和并行性，我们实现了akka流-kafka用户分别订阅每个主题分区，从而实现了用户和分区之间的1:1映射。根据RangeAssignor分区策略(默认策略)，每个分区将被分配给不同的用户，400个消费者将使用400个分区，20个消费者将保持未使用状态。我们已经核实了这一分配，看上去不错。" %% "akka-http"
浏览 4提问于2021-10-28得票数 2
2回答
我使用的是来自的消费者。kafka版本为0.10.1.0。下面是我的消费者的配置： "bootstrap.servers":如果有一条消息到达某个分区，而该分区的offset和lag未知，则offset和lag将重新可见，该消息将被消费。当有一些分区的当前偏移量和</em
浏览 0提问于2018-10-02得票数 2
:8081",} 我正在使用docker-compose来运行包含以下图像的kafka堆栈容器: zookeeper:3.4.9，confluentinc/cp-kafka:5.5.1，confluentinc/cp-schema-registry:5.5.1，confluentinc/cp-kafka-connect:5.5.1 我使用的是flink 1.12.0，下面是我的WOR
浏览 670提问于2021-02-01得票数 0
回答已采纳
2回答
我想实现分布式日志记录，为此我找到了一个使用elk的解决方案。但我不想干扰我当前将日志写入多个文件的体系结构。PS。我目前正在使用log back进行日志记录。
浏览 0提问于2018-06-14得票数 0
我一直在使用kafka主题的事件，在我的应用程序中处理同样的事件已经有一段时间了。该主题有20个分区，我将kafka并发设置为10，因为我使用来自kafka主题的事件和我的应用程序的2个副本。我将提交模式设置为手动立即，因此，一旦应用程序确保事件得到处理，我希望提交分区偏移量。一切都很好，直到卡夫卡服务器的一个或多个节点被关闭并重新启动的一天。我们使用</
浏览 9提问于2021-01-30得票数 2
2回答
我发现了如何从mysql加载数据，但它正在导出完整的数据库，有没有办法保持我的mysql DB和Hadoop之间的数据同步？
浏览 2提问于2020-03-07得票数 1
1回答
我试图为一个应用程序编写Junit测试，该应用程序使用kafka流将数据从kafka发送到websocket连接。我已经能够在本地运行应用程序，发布到主题并看到套接字连接上返回的数据。;import akka.stream.testkit.javadsl.TestSinkthis.cleanUpAdmin
浏览 3提问于2022-02-09得票数 0
5回答
卡夫卡对卡夫卡流
、、、、
我知道，基于Akka的方法实现了反作用规范，并处理了kafka流似乎缺乏的背压和功能。
卡夫卡流比卡夫卡流有什么优势？
浏览 6提问于2017-08-11得票数 49
回答已采纳
1回答
我有一个问题，我需要优先处理一些事件，以便更早地处理，而有些事件则是在高优先级事件之后进行的。这些事件来自一个源，我需要根据它们的事件类型优先级来确定流的优先级，要么在高优先级接收器中转发，要么在低优先级接收器中转发。我用的是卡夫卡和卡夫卡流。
浏览 3提问于2021-09-22得票数 0
回答已采纳
我使用的是1.0.0的Kafka-client版本和2.0.2的Spring-cloud-stream版本。现在我想知道Spring-cloud-stream-binder-kafka的版本，以便将事件流式传输到kafka。(KafkaTopicProvisioner.java:259) ~spring-cloud-stream-binder-kafka-core
浏览 73提问于2019-01-08得票数 1
2回答
我是新的火花和卡夫卡和我有一个稍微不同的使用模式火花流与卡夫卡。_2.10 - 0.10.1.1 kafkaParams.put("auto.offset.reset", "latest");
kafkaParams.put("group.id", "test-consumer-group//
浏览 3提问于2017-08-29得票数 4
回答已采纳
我在第一服务器使用apache kafka，在第二服务器使用apache动物园管理员。我希望在其他server.Is中有卡夫卡连接服务，可以使用独立的服务。我需要阿帕奇卡夫卡连接或融合卡夫卡连接。
浏览 7提问于2022-06-29得票数 0
我以这种方式创建了一个流和一个表： CREATE STREAM user_stream WITH (kafka_topicuser_topic', value_format='json', partitions=1);
SELECT LATEST_BY_OFFSET(name) as name,
LATE
浏览 8提问于2021-06-29得票数 0
云服务器
ICP备案
云直播
对象存储
实时音视频
腾讯云开发者
