腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(41)
视频
沙龙
1
回答
filebeat可以将一个数据传输到logstash和
kafak
吗?
、
、
我想使用filebeat向logstash和
kafak
发送一个日志,然后logstash将日志发送到es,我可以在es中搜索它,
kafak
使用它来分析数据。
浏览 5
提问于2020-05-26
得票数 0
1
回答
Logstash JSON代码和Ruby无法正确处理小数(浮点数)
、
、
我有
Kafak
<> Logstash (然后是Ruby) <>弹性
Kafak
输入: {"customerid":"smit","last_name":"shah","age":10,"height
浏览 59
提问于2020-09-11
得票数 0
1
回答
可以单独使用Flume Kafka Source吗?
、
、
假设有一群生产者将avro记录(具有相同的模式)写入到
Kafak
主题中。 我可以使用Flume Kafka Source读取这些记录并将它们写入HDFS吗?
浏览 21
提问于2019-09-13
得票数 1
回答已采纳
1
回答
JSON未在Kafka中格式化
、
、
、
"TS", "lineIds" : [ {"sublineIds" : [ "1" ]} 此字符串将发送到
Kafak
浏览 82
提问于2020-05-02
得票数 0
回答已采纳
1
回答
kafka 0.8.0升级到0.9.0
、
2181 --replica 1 --partition 10 --replica-assignment-list 1,1,1,1,1,1,1,1,1,1 --topic unified-events 在
kafak
浏览 0
提问于2017-05-26
得票数 0
1
回答
Kafka Streams -通过交互式查询在远程存储中进行查找的最佳方式?
、
我有点困惑,我想要澄清一下。我有点事要做。我想要有一个Kafka Streams拓扑,它将有五个独立的KStreams从各自的主题读取数据,并将数据转储到一个大型的整体主题中。接下来,我将创建一个GlobalKTable,它将从这个整体主题中读取内容,并实现一个全局存储,比方说,称为lookupStore。我想让这个物化的全局存储基本上作为其他Kafka Streams应用程序的“查找”表。我已经阅读了一些关于使用带有application.server配置的RPC层来公开这一点的文章,该RPC层将以一些独特的host:port的形式出现。 现在,我想要有许多独立的微服务,每个微服务都是Ka
浏览 41
提问于2020-11-11
得票数 0
2
回答
我们需要手动缓存模式注册表吗?
、
、
、
、
我们目前正在使用协议缓冲区作为
kafak
消息的序列化机制。我们要搬到阿夫罗去。我们用Schema测试了Avro汇合消费者,根据这些测试,Avro使用者与原型消费者相比有点慢。
浏览 0
提问于2018-05-04
得票数 0
回答已采纳
1
回答
在集群外监听
kafak
on kubernetes
、
、
、
我在谷歌云平台上运行了一个kubernetes集群,并使用Helm charts在上面安装了kafka ()。我还有另一个运行python pod的部署。我已经使用LoadBalancers公开了kafka和zookeper。下面是我运行kubectl get all时得到的结果(IP地址已更改)pod/my-kafka-0 1/1 Running 1
浏览 15
提问于2019-07-17
得票数 0
1
回答
实时数据采集和离线处理
、
、
我有源源不断的数据。我想对数据进行少量的实时处理(主要是压缩、滚动一些数据,不管需要做什么),然后存储数据。大概没问题。HDF5文件格式应该做得很好!OOC数据,没问题。皮特茅斯。人们是怎么做到的?部分解决办法: 看来HDF5-1.10.0具有单写、多读的SWMR功能.这似乎正是我想要的。我找不到这个最新
浏览 5
提问于2016-05-08
得票数 0
1
回答
kafka.utils.TestUtils.tempDir(TestUtils.scala):scala/java.lang.NoClassDefFoundError/GenTraversableOnce
、
、
、
、
org.springframework.boot:spring-boot-starter-validation") implementation("org.springframework.kafka:spring-
kafak
浏览 1
提问于2020-09-09
得票数 1
回答已采纳
1
回答
卡夫卡连接器在发生故障时是如何可靠的?
、
它能够再消费同样的数据从
Kafak
以后吗? 对于源连接器(JDBC ),如果它不能发送给Kafka,它以后会重新处理相同的数据吗?这取决于来源是什么?
浏览 0
提问于2018-08-22
得票数 1
1
回答
在Kafka中,为什么我们在使用分区时没有并行性?
、
为什么
Kafak
不允许从一个已经被另一个消费者消费的分区中消费信息,而不是将新的消费者置于闲置状态?如果发生这种情况,就会有更多的并行性。
浏览 2
提问于2022-02-28
得票数 0
1
回答
是否有一种方法可以将卷装载到kubernetes坞组合部署中?
、
、
、
the host - /home/centos/Sprint0Demo/Servers/elasticSearchConnector
浏览 2
提问于2019-11-05
得票数 0
1
回答
从hadoop到
kafak
的NiFi保证只有一次
、
、
NiFi是否有可能从hdfs (或hive)读取数据,并将数据行发布到kafka,并保证只交付一次?
浏览 12
提问于2020-11-17
得票数 0
1
回答
Spring 2 MessageHandlers处理一半的消息
、
、
(如果禁用
kafak
处理程序,则第二个处理程序将获取所有n条消息)我需要订阅从同一个通道获取所有消息(kafka处理程序将对原始数据进行处理,而jdbc处理程序将推动转换后的数据)
浏览 1
提问于2021-04-21
得票数 0
回答已采纳
1
回答
启用TLS的私有VPC访问上的Amazon集群
、
、
、
、
我在一个私人VPC上有一个AWS MSK kafka集群。我已经设置了一个堡垒来连接到这个集群,并且可以使用kafka控制台命令和使用用于SSL auth的JVM密钥存储成功地从这个堡垒生成和使用消息。这是我的SSH隧道命令:ssh -i ~/bastion.pem -N ec2-user@ec2-myhost.compute.amazonaws.com -L 9094:kafkacluster.amazonaws.com:9094 -v 然后在我的mac上本地运行
浏览 1
提问于2020-06-05
得票数 0
1
回答
冰山:如何快速穿过一张很大的桌子
、
、
我们希望把这个表中的所有记录传送到其他数据库,比如pg,
kafak
,等等。
浏览 3
提问于2022-01-07
得票数 0
2
回答
Spark.jars未将jars添加到类路径
、
、
、
我正在尝试使用"spark.jars“属性在spark作业中添加我的自定义jar。虽然我可以读取添加jar的日志中的信息,但是当我检查添加到类路径中的jar时,我没有发现it.Below是我也尝试过的函数。2)spark.driver.extraLibraryPath4)setJars(SeqString)对me.Spark.jars起作用的第一个选项是添加jar,因为它在Spar
浏览 4
提问于2018-03-21
得票数 0
1
回答
从writeStream读取到json文件,但在HDFS json文件中只找到一条消息。
、
、
我尝试过控制台(writeStream.format(“控制台”)或
kafak
(writeStream.format("kafka"))的接收器类型,它正常工作。有什么建议或意见吗?下面是示例代码。
浏览 2
提问于2022-08-27
得票数 0
3
回答
Kafka -码头-在从主机发送消息到容器时出错(批处理过期)
、
我正在尝试发布一些来自
kafak
-console-producer的消息。
浏览 3
提问于2016-01-25
得票数 9
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Kafak的吞吐量为何这么高呢?
kafka日志存储以及清理机制
012-Ambari二次开发之组件Zookeeper,Kafka,Hadoop编译
Kafka Eagle V 发布!欢迎star
4.kafka生产者&消费者
热门
标签
更多标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
活动推荐
运营活动
广告
关闭
领券