腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
ModuleNotFoundError
("'
kafka
‘
不是
一个
合法
的
名字
。
你
是
指
aiokafka
,
kafka
吗
?“)
python
、
django
、
apache-kafka
、
django-celery
、
faust
我正在使用芹菜和
Kafka
来运行一些作业,以便将数据推送到
Kafka
。我还使用Faust来连接工人。但不幸
的
是
,在运行faust -A project.streams.app worker -l info以运行管道之后,我得到了
一个
错误。我想知道有没有人能帮我。warnings.warn(WARN_DEBUG_ENABLED) Command raised exception:
ModuleNotFoundError
("'
kafka
' is
浏览 53
提问于2021-07-11
得票数 0
回答已采纳
1
回答
Python
Kafka
客户端无法连接到远程
Kafka
服务器
python
、
apache-kafka
我有
一个
云上
的
Ubuntu,在那里我从下载了
Kafka
版本2.8.1,并遵循了中
的
说明。
kafka
.errors.KafkaConnectionError: KafkaConnectionError: No connection to node with id 0import asyncio import
aiokafka
浏览 23
提问于2022-04-22
得票数 0
回答已采纳
1
回答
在码头组合文件中设置
Kafka
用户级配置
docker
、
apache-kafka
我有一种情况,我有两个对接者撰写文件:其中
一个
包含卡夫卡图像,另
一个
包含卡夫卡所消耗
的
其他过程。
KAFKA
_ADVERTISED_PORT: "9092"
KAFKA
_LISTENERS: "INTERNAL://
kafka
:9092,EXTERNAL://0.0.0.0:9093"
KAFKA
_ADVERTISED_LISTENERS: "INTERNAL:/
浏览 4
提问于2022-08-02
得票数 0
1
回答
库伯奈特斯为卡夫卡创造但未在POD中反映
的
终结点
spring-boot
、
kubernetes
、
apache-kafka
、
spring-kafka
、
kubernetes-service
在Kubernetes集群中,我创建了指向
Kafka
集群
的
端点。成功创建终结点。
名字
-
kafka
env: value:
kafka
POD处于错误状态。在我
的
bootstrap-server中,我得到
的
是
kafka
,而<e
浏览 0
提问于2019-08-19
得票数 1
1
回答
AMBARI +如何在中设置值
json
、
bash
、
api
、
ambari
下面的API示例将在stop中
kafka
服务ambari所以ambri看到
的
名字
是
- PARSE.STOP.$service而
不是
PARSE.STOP.
kafka
知道如何在
浏览 2
提问于2020-02-24
得票数 0
回答已采纳
1
回答
Spring-
Kafka
没有选择SSL配置。
java
、
spring-boot
、
ssl
、
apache-kafka
、
spring-kafka
我正试图连接到
Kafka
broker,后者执行双向SSL/TLS来验证和授权客户端。我已经通过正确
的
权限创建了证书签名,并存储在我
的
本地用户目录中。我在用我
的
application.propertiesspring.
kafka
.topic=lucija-eliza-topi
浏览 5
提问于2022-08-29
得票数 0
回答已采纳
1
回答
使用带有Spark
的
Kafka
比仅使用Spark
的
优点
apache-spark
、
apache-kafka
、
stream-processing
Kafka
是
很常见
的
。所以很多公司都在使用它。我完全理解
Kafka
和Spark
是
如何工作
的
,我对他们都很有经验。我不理解
的
是
用例。为什么
你
要把
Kafka
和Spark一起使用,而不仅仅是Spark呢?在我看来,
Kafka
的
主要用途
是
作为ETL管道中
的
中转区,用于实时(流)数据。 我假设有
一个
数据源集群,数据最初存储在其中。例如,它
浏览 3
提问于2019-06-17
得票数 3
1
回答
用
Kafka
代替File拍和Logstash
elasticsearch
、
logging
、
apache-kafka
、
logstash
、
filebeat
我
是
麋鹿堆栈
的
新手,我只是想知道是否可以使用
Kafka
将日志文件发送到Elasticsearch。,但我也需要用 grok 这样
的
过滤器来解析日志。
是
可能
的
吗
?基本上,我要做
的
是
用卡夫卡取代Filebeats和Logstash
的
组合,我想知道这是否可能。注意:我试图做
的
是
Ship +分析在
Kafka
中
的
日志。我知道使用elastic
浏览 0
提问于2018-07-18
得票数 3
回答已采纳
1
回答
卡夫卡能直接连接创造流
吗
?
apache-kafka-streams
、
apache-kafka-connect
、
ksqldb
我
的
理想
是
,
kafka
创建与表相对应
的
主题,然后由我声明性地(使用KSQL)创建视图。更具体地说,视图通常表示表上
的
联接。但
浏览 2
提问于2019-07-06
得票数 0
回答已采纳
1
回答
k3s和
kafka
网络-端口因某种原因而被阻塞
confluent-platform
、
k3s
下面
是
在k3s环境中运行
kafka
的
设置。动物园管理员一开始就毫无障碍地开始,而且很快乐。无论卡夫卡,第
一个
副本开始很好,但它从来没有得到第二个副本,因为readinessProbe失败。我可以用FQDN
的
名字
,ping
kafka
-app-0.
kafka
-app.avc.svc.cluster.local来平卡夫卡。然而,nc
kafka
-app-0.
kafka
-app.svc.cluster.
浏览 2
提问于2021-09-08
得票数 0
回答已采纳
1
回答
Nifi,如何通过
Kafka
avro文件生成每个文件
的
多个记录
json
、
apache-kafka
、
apache-nifi
、
avro
我创建了
一个
处理单个json文件
的
管道(
一个
由5890个元素组成
的
向量,每个元素都是
一个
记录),并以avro格式通过
Kafka
发送。生产者工作正常,然后当我与消费者一起阅读它时,我会得到每个记录
的
流文件(
一个
avro文件)。5890阿夫罗档案如何在
一个
avro文件中设置或合并更多记录?
浏览 4
提问于2022-02-11
得票数 0
回答已采纳
1
回答
Logstash-
Kafka
集成不起作用
log4j
、
slf4j
、
logstash
、
apache-kafka
我们想要使用logstash获取日志并将它们传递给
kafka
.topic_id => "example1" }运行以下命令后:bin/logstash代理-f test.conf --日志ex.log我们得到以下输出 将日志存储日志发送到ex.log。使用里程碑2输入插件‘文件’。这个插件应该是稳定
的
浏览 4
提问于2014-12-16
得票数 0
回答已采纳
2
回答
增加
Kafka
中主题数导致zookeeper失败
apache-kafka
、
apache-zookeeper
、
iot
我们计划使用
kafka
作为IoT用例
的
消息代理,其中每个设备都被视为唯一
的
主题。当我模拟每秒10条消息到10000个主题zookeeper遇到瓶颈时,所有
Kafka
监控工具都无法从JMX端口读取吞吐量值和主题数量。will调优zookeeper将会解决这些问题。我想确保这种方法
是
完美的。请提个建议。
浏览 1
提问于2016-05-16
得票数 2
1
回答
我们真的需要它
吗
?它
不是
用了耳聋
的
吗
?
apache-flink
、
flink-streaming
我们真的对操作符使用uid方法
吗
?
你
能不能建议一种更优雅
的
方式来设置它(就像c#中
的
扩展方法),而
不是
同时为name和uid传递2次字符串?例如,而
不是
: .addSource(new KafkaConsumer(kafkaConsumerOptions)) .name("
Kafka
topic reader").uid("
浏览 9
提问于2019-10-31
得票数 0
1
回答
如何在Storm上创建同步KafkaSpout
apache-kafka
、
apache-storm
我正在尝试让
一个
Kafka
消费者同时消费来自
Kafka
的
消息。KafkaSpoutConfig spoutConf = KafkaSpoutConfig.builder("stream1:9092&q
浏览 8
提问于2019-11-20
得票数 0
回答已采纳
2
回答
使用Apache作为FTP
的
替代方案
apache-kafka
、
ftp
我只想知道我们是否可以使用Apache作为我们
的
常规FTP
的
替代方案,在这里,我们将文件保存在某个位置,而最终用户则访问这些文件。我
的
文件来源将主要是SAP HANA。从我想要将文件推入
Kafka
的
地方,最终用户可以在那里使用它。有人能建议从哪里开始或列出实现这一目标的步骤
吗
?
浏览 0
提问于2019-07-10
得票数 1
回答已采纳
1
回答
金刚卡夫卡溪流
go
、
apache-kafka-streams
我正在尝试使用golang在Go中创建
一个
kafka
流客户端。据我所见,这只有在使用Java客户机时才有可能。我做了一些搜索,并找到了其他一些第三方图书馆,但没有正式
的
。另外,根据我有限
的
理解,我认为流
是
语法糖而
不是
标准消费者
吗
?这是对
的
吗
?
浏览 4
提问于2021-12-13
得票数 1
1
回答
检索id % 1
的
Avro架构时出错,找不到主题。;错误代码: 40401
apache-kafka
、
avro
、
confluent-platform
、
confluent-schema-registry
found.; error code: 40401我使用KTable消费来自几个主题(topic_1,topic_2)
的
数据,连接数据,然后使用KStream将数据推送到另
一个
主题Topic_out
的
输出:
kafka
-avro-console-consumer --bootstrap-server localhost:9092 --from-beginning --property为什么subject with key
是
必需
的
?我将这个主题提供给另<
浏览 0
提问于2018-05-25
得票数 2
回答已采纳
3
回答
Kafka
broker启动内存问题
hadoop
、
ubuntu-14.04
、
apache-kafka
、
hadoop-streaming
我
是
卡夫卡和Hadoop技术
的
新手。我试图在AWS EC2 VM实例上安装和运行我
的
第
一个
单一节点,即单个代理集群,我已经完成了以下工作:2)用java相关条目更新~/.bashrc and ~/.nash_profile文件4)一旦我试图启动
kafka
broker,它就会向我抛出以下错误信息: $ bin/
kafka
-server-start.sh config/server.pr
浏览 3
提问于2015-08-13
得票数 3
回答已采纳
1
回答
Java消费者群体未能使用几条消息
java
、
apache-kafka
注意到
一个
问题,其中
Kafka
消费者组(用java实现)始终遗漏了来自代理
的
几条消息。作为调试
的
第一行,通过
kafka
控制台使用者,我可以在代理中看到这些消息。
Kafka
broker版本: 0.10.1.0<dependency> <artifactId>
kafka
_2.
浏览 2
提问于2017-12-22
得票数 6
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
hadoop,spark,这些名字都是怎么来的呢?
银行系统中的消息分发利器Kafka(二)
Kafka实战四-Kafka门派知多少
Kafka是如何检查文件完整性的
系统解读Kafka的流和表(二):主题、分区和存储
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券