腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
将
Apache
Kafka
与
python
一起
使用
而
不是
Java
有
什么
缺点
吗
?
java
、
python
、
apache-kafka
我正在用
python
开发一个应用程序,我必须
使用
Apache
-
Kafka
。我对卡夫卡非常陌生。 我读到
python
不支持
Kafka
的事务生产者/消费者。我只想知道这个缺陷会有
什么
大的不同,因为我必须将我的
python
应用程序转换为
java
,然后
使用
Kafka
?另外,
使用
Kafka
-
python
还有其他
缺点
吗</
浏览 16
提问于2020-07-13
得票数 0
回答已采纳
1
回答
浮士德
与
卡夫卡-蟒蛇的区别
python
、
apache-kafka
、
faust
我找不到任何答案:和
有
什么
区别? 所以,如果我计划只<em
浏览 0
提问于2021-01-31
得票数 5
回答已采纳
1
回答
Kafka
2.1.0
Java
消费者对Scala消费者
java
、
scala
、
apache-kafka
我想将我的团队的
Kafka
集群从0.10.1.1升级到2.1.0。顺便说一句,卡夫卡的官方文件说了以下几句话。请注意,不再维护的旧Scala客户端不支持0.11中引入的消息格式,因此为了避免转换成本(或充分利用一次语义),必须
使用
较新的
Java
客户端。 我不太理解那句话。目前,我们的团队正在
使用
用Scala编写的
Kafka
消费者应用程序。但是我们应该把它变成
Java
吗
?如果我们现在
使用
Scala编写的应用程序,我不知道它到底会有
什么</e
浏览 0
提问于2019-01-03
得票数 1
1
回答
在
kafka
connect中
使用
Json架构和架构注册表时出错
apache-kafka
、
jsonschema
、
apache-kafka-connect
、
confluent-schema-registry
我正在尝试
将
JsonSchema
与
模式注册表
一起
使用
。它提供了一些
与
代码相关的错误。 有没有人成功试用过JsonSchema。
java
.lang.NoSuchMethodError: io.confluent.
kafka
.serializers.subject.strategy.SubjectNameStrategy.subjectName(Ljava/lang/String;ZLio/confluent/
kafka</e
浏览 13
提问于2020-09-09
得票数 1
3
回答
KafkaEmbedded为SecurityProtocol抛出ClassNotFoundException
java
、
spring
、
spring-kafka
我
使用
的是spring-boot-parent 1.5.10.RELEASE。> </dependency>
java
.lang.NoClassDefFoundError: org/
apache
/: org.
apache
.
kafka
.common.security.auth.SecurityProtocol at
java</
浏览 0
提问于2018-02-16
得票数 6
回答已采纳
1
回答
当序列化一个
Kafka
对象时,我会得到"org.
apache
.
kafka
.common.errors.SerializationException:未知的魔法字节!“
java
、
serialization
、
apache-kafka
、
avro
、
spring-kafka
我
有
一个
Java
应用程序,它
使用
Kafka
来
使用
Avro消息。 在我的测试中,我
将
Avro对象序列化为byte[],并将其
与
KafkaTemplate<String, byte[]>
一起
发送到主题。: failed to deserialize; nested exception is org.
apache
.
kafka
.common.errors.SerializationException: Error
浏览 2
提问于2021-05-05
得票数 0
回答已采纳
1
回答
使用
Kafka
队列中的数据的流式作业
与
循环批处理作业
java
、
loops
、
apache-kafka
、
streaming
、
kafka-consumer-api
例如,如果我
有
一个总是在运行的
Java
应用程序,它在数据到达时从
Kafka
队列中读取数据,目的是获取数据并将其转发到数据库...无限循环通过批处理作业,
而
不是
通过
Kafka
Streaming/
Kafka
Connect进行,
有
什么
主要的
缺点
吗
?考虑到我没有在每个循环中毫无意义地创建或浪费资源,而且我正确地处理了多线程,有没有
什么
主要的
缺点
或理由不这样做呢
浏览 5
提问于2019-03-28
得票数 1
回答已采纳
2
回答
存储流事件的建议
apache-kafka
、
apache-kafka-streams
、
event-stream
、
event-stream-processing
我们计划
使用
Kafka
作为中间层,吸收来自不同用户浏览器的大量流数据。然而,我很想知道
Kafka
是否也可以作为一个持久的数据库来存储这些事件,以便我们以后可以构建仪表板应用程序,并让它通过我们设计的一些后端web API来查询事件。我可以想象如果
使用
Kafka
作为持久DB,那么可能是降低存储成本的一种可能的解决方案。总的来说,为了能够设计一个定制的仪表板来查询已摄入的事件流,是否应该
使用
Kafka
作为DB替换,还是应该考虑
将
Kafka
浏览 18
提问于2022-03-30
得票数 0
2
回答
连接到节点ubuntukafka时出错:9092 (id: 0 rack: null) (org.
apache
.
kafka
.clients.NetworkClient)
java
.net.UnknownHostException
java
、
python-3.x
、
apache-kafka
、
virtualbox
我可以通过SSH从我的主机连接到这两台机器,并且在这两台机器之间
使用
natnetwork。:151) at org.
apache
.
kafka
.clients.NetworkClient.ready
而
不是
ubuntukafkanode),但是失败了。我错过了
什么</em
浏览 1031
提问于2019-09-17
得票数 7
回答已采纳
2
回答
Flink -
kafka
连接器OAUTHBEARER类加载程序问题
apache-kafka
、
apache-flink
、
flink-streaming
、
jaas
、
sasl
我尝试
使用
sasl机制(OAUTHBEARER)配置
kafka
身份验证(
使用
flink 1.9.2,
kafka
-client 2.2.0)。我不知道为
什么
这两个类
有
两个不同
浏览 6
提问于2021-09-06
得票数 1
2
回答
Kafka
: Scala到
Python
的转换
python
、
apache-spark
、
pyspark
、
apache-kafka
、
spark-streaming
参考:impo
浏览 5
提问于2019-10-31
得票数 0
回答已采纳
2
回答
在
Kafka
中实现反序列化器和Serde
有
什么
区别?
java
、
apache-kafka
、
kafka-consumer-api
、
apache-kafka-streams
但是,我试图理解为
什么
使用
自定义serde来反序列化,然后
使用
者API就会产生错误,因为它
不是
org.
apache
.
kafka
.common.serialization.Deserializer的一个实例可以
使用
KTable
与
Serdes.Integer()序列化程序和新的ProfileSerde()反序列化器
一起
使用
该主题,如下所示。<init>(KafkaConsumer.
java
:
浏览 0
提问于2019-05-24
得票数 4
回答已采纳
1
回答
Mesos 'master‘和'slave’节点可以部署在同一台机器上
吗
?
apache-zookeeper
、
mesos
、
mesosphere
Apache
Mesos“主”节点是否可以
与
Mesos“从”节点位于同一台机器上?同样(对于高可用性(HA)部署),在Mesos“主”选举中
使用
的
Apache
Zookeeper节点可以部署在
与
Mesos“从”节点相同的机器上
吗
?Mesos建议
将
3个“master”用于HA部署,Zookeeper建议
将
5个节点用于其法定选举系统。让这些服务
与
Mesos的“从属”进程
一起
运行,
而
不是
浏览 33
提问于2014-10-28
得票数 16
回答已采纳
1
回答
kafka
.javaapi.*和org.
apache
.
kafka
.*之间
有
什么
区别?
api
、
apache-kafka
我是
kafka
.But的新学习者,让我感到困惑的是,似乎
有
两个卡夫卡客户包。import
kafka
.javaapi.producer.Producer;import
kafka
.producer.ProducerConfig;import org.
apache
浏览 3
提问于2015-03-27
得票数 14
回答已采纳
3
回答
如何
使用
Kafka
从文件中读取新条目
hadoop
、
apache-kafka
、
kafka-producer-api
这是我要从文件中读取的
Kafka
代码: prop.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG,"org.
apache
.
kafka
.common.serialization.B
浏览 3
提问于2016-05-22
得票数 0
3
回答
如何
将
数据集写入
Kafka
主题?
scala
、
apache-spark
、
apache-kafka
、
apache-spark-sql
我
使用
的是Spark 2.1.0和
Kafka
0.9.0。有没有人知道这样的事情是否可行?我用的是spark shell: spark-shell --packages org.
apache
.spark:
浏览 3
提问于2018-04-06
得票数 6
1
回答
TwitterSourceConnector必须是SourceConnector的子类
apache-kafka
、
apache-kafka-connect
卡夫卡连接推出通过docker-compose卡夫卡-集群
与
基地:landoop/fast-data-dev:lastest,其中最近的结果是卡夫卡连接版本2.6.2-LO,也尝试了2.6.2-LO。connector": { "worker_id": "127.0.0.1:8083", "trace": "org.
apache
.
kafk
浏览 0
提问于2021-08-19
得票数 0
1
回答
PLC4X -
Kafka
连接器
apache-kafka
、
apache-kafka-connect
、
apache-plc4x
、
plc4x
我想
使用
PLC4X连接器()
将
OPC (Prosys模拟服务器)
与
Kafka
连接起来。我来自接收器
python
连接器的输出如下所示。对我来说也有点奇怪
吗
?转换器和架构
一起
浏览 6
提问于2022-05-06
得票数 0
1
回答
Apache
的本地二进制TCP协议相对于restful
有
什么
好处?
apache-kafka
根据
Apache
的文档,
Kafka
在其本地API的通信中
使用
了二进制TCP协议,但它们也为不支持
Apache
的本地API的语言提供了基于URL的restful。我只是想知道本地二进制TCP协议(在本机API中支持)是否比基于restful的
与
代理节点的通信
有
什么
好处?我还在想restful是否还会维护only once属性呢?编辑: restful指南在这里:,它解释了如何在restful上生成和
使用
Kafka
的消息
浏览 1
提问于2017-09-24
得票数 2
回答已采纳
1
回答
使用
python
的Spark 2.3.0中的spark
Kafka
流媒体
apache-spark
、
pyspark
、
apache-kafka
、
spark-streaming
、
spark-streaming-kafka
我
有
一个现有的spark作业,它曾经在spark 2.2.0上运行。(GatewayConnection.
java
:214) at
java
.lang.Thread.run(Thread.
java
:745) 我
使用
带有-packages选项的spark-submit我尝试
将
spark-streaming-
kafka
-0-8-assembly_2.11-2.3.0.jar
与
--package和--jars选项
一起
使用</
浏览 14
提问于2018-12-19
得票数 3
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
盘点:2020年最受欢迎的6种编程语言
KSQL:Apache Kafka的开源Streaming SQL引擎
程序员经典面试题,Kafka读写硬盘为什么速度还那么快
Apache Spark框架下,Python与Scala谁更胜一筹?
SparkStreaming&Kafka——Receiver方式
热门
标签
更多标签
云服务器
ICP备案
实时音视频
对象存储
云直播
活动推荐
运营活动
广告
关闭
领券