腾讯云
开发者社区
文档
建议反馈
控制台
登录/注册
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
如何
通过
akka-
ProducerSettings
-
kafka
中
的
配置
(
application.conf
)
创建
流
?
、
我正在尝试学习和使用akka-stream-
kafka
,并且正在阅读它
的
文档。在生产者设置部分,它告诉我们可以
通过
编程和从
配置
创建
ProducerSettings
。有一个编程构造
的
示例,但没有
如何
通过
配置
创建
它
的
示例。程序化
的
构造很简单,下面是一个例子。然而,我想使用
配置
库结构,并希望
配置
来自
application.co
浏览 2
提问于2017-08-04
得票数 0
回答已采纳
2
回答
如何
由Alpakka
创建
多个分区
、
、
我正在尝试
创建
一个简单
的
生成器,它用
配置
提供
的
一些分区
创建
一个主题。根据,来自org.apache.
kafka
.clients.producer.ProducerConfig
的
任何属性都可以在
kafka
-clients部分
中
设置。并且,有一个num.partitions属性,如
中
的
注释。 因此,我将该属性添加到我
的
application.conf
文件
中</
浏览 2
提问于2019-04-04
得票数 0
回答已采纳
4
回答
Akka Stream
Kafka
:没有为关键
的
“
kafka
-客户端”找到
配置
设置
、
、
、
、
我正在尝试使用
创建
一个简单
的
原型。我没有
配置
任何uber/程序集jar。正如@终冷调用
ProducerSettings
(system, new StringSerializer, new StringSerializer) (传递ActorSystem而不是
配置
)所建议
的
那样我只是不明白这是故意
的
还是错误
的
。我已经
创建<
浏览 0
提问于2018-06-18
得票数 2
回答已采纳
1
回答
如何
让远程
创建
的
演员?
、
如何
让远程
创建
的
演员?部署在host2上
的
应用程序将
通过
配置
在host1上远程
创建
一个参与者:remote_app { includeremoteActor = system.actorOf(Props[AdvancedCalculatorApplication
浏览 2
提问于2012-03-15
得票数 0
1
回答
Kafka
大消息
配置
、
我读了很多关于
配置
的话题,但我还是不明白。../
kafka
_2.11-1.1.0/bin/
kafka
-topics.sh --zookeeper localhost:2181 --alter --topic my_topic --config max.message.bytes=10000000但在我
的
应用程序
中
,我尝试了所有的方法 def
producerSettings
(system: ActorSy
浏览 0
提问于2018-08-30
得票数 0
回答已采纳
1
回答
akka
流
自定义图阶段
、
、
我有一个来自像这样
的
web套接字
的
akka
流
,并且希望构建一个可重用
的
图形阶段(inlet:这个
流
,FlowShape:添加一个额外
的
字段到JSON
中
,指定原点:...,} 无法从web套接字
流
中
创建
自定义Inlet。无法将
kafka</em
浏览 2
提问于2017-05-02
得票数 0
回答已采纳
0
回答
如何
检查avro架构注册表
的
使用情况
、
、
、
、
我正在
通过
avro4s使用avro。这是我对消费者/生产者
的
配置
.withProperty("value.serializer", "io.confluent.
kafka
.serializers.KafkaA
浏览 13
提问于2018-07-16
得票数 0
回答已采纳
3
回答
卡夫卡制片人不写卡夫卡主题
、
、
很抱歉有个问题:我正在用akka写信给
kafka
,但是我在
kafka
控制台上看不到它。用于写入
kafka
的
配置
: bootstrap.servers = "localhost:9002"} 我有代码可以用val
producerSettings
:
ProducerSettings
[String, String] =
P
浏览 0
提问于2018-11-21
得票数 2
回答已采纳
1
回答
在
kafka
中
处理大型Xml文件
、
、
、
我正在使用Alpakka
kafka
和scala应用程序。我
的
Kafka
在docker内部运行,我正在尝试使用我
的
代码在
Kafka
producer上发布消息。(
producerSettings
) producer.send(new ProducerRecord("topic_name", "Key", xmlFile)).map(result =文件时,它会给出an error that org.apache.
kafka</e
浏览 4
提问于2020-07-17
得票数 1
1
回答
如何
包含多个自定义
配置
文件以播放
application.conf
文件
、
在我
的
播放项目中,我有大约3个自定义
配置
文件。包括“邮件” 我是否可以立即添加它们,或者只需在
配置
文件中一个接一个地添加它们。
浏览 1
提问于2016-05-13
得票数 0
1
回答
将Lagom框架部署为独立
的
jar/docker
、
、
是否可以将Lagom应用程序部署为独立运行
的
jar或Docker容器?如果是,怎么做?
浏览 0
提问于2019-01-25
得票数 3
回答已采纳
1
回答
如何
将Http管理到Akka
流
并将消息发送给
Kafka
?
、
、
、
、
我从Akka开始,我想构建一个服务器作为
流
,它接收一个Http.IncomingConnection并将接收到
的
消息作为plainSink发送给卡夫卡。().bind(interface = "localhost", port = "8080")但是,我不知道
如何
提取信息。"), _, _, _) =
浏览 0
提问于2018-10-10
得票数 1
回答已采纳
1
回答
如何
使用${akka.
kafka
.consumer}?
、
我正在尝试使用默认
的
Kafka
配置
设置,但我不确定${akka.
kafka
.consumer}是
如何
设置
的
。阅读我定义了以下内容:our-
kafka
-consumer: ${akka.
kafka
.consumer} {
kafka
-clients {bootstrap.servers = "
kafka
-host:909
浏览 18
提问于2022-02-28
得票数 0
回答已采纳
1
回答
使用环境变量设置类型列表
的
Play Framework
配置
变量
、
、
我要做
的
是将list类型
的
配置
变量设置为环境变量。我知道我可以像这样使用env变量:但是,我不知道
的
是env var看起来
如何
才能被接受为类型列表。我试过:["item1","item2"]这三个符号都会抛出一个
配置
异常:
配置
错
浏览 0
提问于2015-02-02
得票数 6
1
回答
在AKS上部署Spring-Cloud-数据
流
时,
如何
使用外部托管
的
Kafka
集群指定?
、
、
、
我已经尝试过基于舵机
的
部署(),它可以使用基于RabbitMQ
的
消息传递系统,也可以使用基于卡夫卡
的
消息传递系统--这两个选项都可以部署在helm图表
中
。但是,我
的
项目已经有了自己
的
Kafka
实例,运行在我想要使用
的
融合云上,而不是“内部”实例。然后,我还尝试了SCDF ()
的
Kubectl部署,并看到我需要再次运行这两个消息传递组件
中
的
一个。我想知道
配置
SCDF以使用我自己<em
浏览 3
提问于2020-07-14
得票数 0
回答已采纳
1
回答
如何
在运行时根据一些值字段
创建
Kafka
主题名称
、
因此所有具有相似字段值
的
records<K,V>都放在Topic_<Field>
中
。
如何
使用kstream完成此操作?
浏览 2
提问于2018-05-23
得票数 1
0
回答
Spring
Kafka
-动态
创建
流
、
、
、
、
我需要从
配置
文件
中
动态
创建
kafka
流
,
配置
文件包含源主题名称和每个
流
的
配置
。App需要有数十个
kafka
流
,每个环境(例如stage、prod)
的
流
都会有所不同。使用spring-
kafka
也可以做到这一点吗?正如我所看到
的
,我们需要在代码
中
创建
每个
kafka
流</
浏览 21
提问于2018-07-13
得票数 2
回答已采纳
1
回答
如何
让
kafka
在spring运行时使用http
流
数据?
、
、
、
在spring运行时,可以让
kafka
源模块作为处理器模块工作吗?有代码样本吗?我正试图实现这样
的
目标: http (xd源)、xd源(xd处理器)、xd使用者(xd接收器)stream create kafkaSourceTest --definition "http --outputType=application/json |
kafka
--zkconnect=localh
浏览 3
提问于2015-05-12
得票数 0
回答已采纳
1
回答
不应用于状态存储更改主题
的
Kafka
流
复制因子
、
、
我们
通过
集成使用
Kafka
流
。我将复制因子
配置
为在所有内部
Kafka
流
主题中使用,方法是设置它适用于大多数由
Kafka
流在内部使用
的
重新分区/变更主题。但是,该设置似乎对
通过
Materialized#as(StoreSupplie
浏览 5
提问于2020-10-14
得票数 1
回答已采纳
1
回答
alpakka jms客户确认模式交付保证
、
、
、
我有一个alpakka源->
kafka
接收器类似于一个
流
。我正在查看alpakka jms消费者文档,并试图找出这能为我提供什么样
的
交付保证。ackEnvelope.message .runWith(Sink.seq) 我希望这实际上是信息只有在沉船成功后才会被破坏(至少一次交付保证),但我不能依赖于一厢情愿
的
想法鉴于alpakka似乎没有利用任何一种在重新启动过程
中
持续存在
的
状态,我想不出我
如何
才能准确地得到--一旦在这里保证了,但我至少可
浏览 14
提问于2022-08-22
得票数 0
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Spark Streaming+Kafka+Hbase项目实战
kafka实战演练,欲走大数据之路的台阶打造,通往的必经之路
从入门到精通-Fayson带你玩转CDH
玩了分布式这么久,你不会连Kafka都不清楚吧
当Flink遇到Kafka-FlinkKafkaConsumer使用详解
热门
标签
更多标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频
活动推荐
运营活动
广告
关闭
领券