腾讯云
开发者社区
文档
建议反馈
控制台
登录/注册
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
2
回答
windows 10上的Apache错误:
kafka
-topics.bat文件给出语法错误
、
我的问题是,当我尝试使用以下命令从cmd创建一个主题时:"%~dp0
kafka
-run-class.bat"
kafka
.admin.TopicCo
浏览 6
提问于2020-07-11
得票数 1
1
回答
如何修复Flink错误:无法推断FlinkKafkaConsumer011<>的类型参数
、
下面是使用Flink和
Kafka
的例子。我只找到像this page这样的结果,它们不能正确编译,并且给出了很难查找的错误消息。org.apache.flink.streaming.util.serialization.SimpleStringSchema; compile group
浏览 170
提问于2019-05-24
得票数 2
回答已采纳
1
回答
我可以查看发送给
Kafka
的模式的id/
版本号
吗?用于调试目的
、
、
如果我有3个版本的模式,并且我正在发布版本1的数据,我可以在将记录发送给
kafka
之前查看
版本号
吗?
浏览 10
提问于2020-01-02
得票数 0
回答已采纳
2
回答
在logstash中安装插件版本
、
、
我可以使用bin/logstash-plugin list 'logstash-input-
kafka
'列出插件,在bin/logstash-plugin的帮助下,我找不到任何标志来查找安装在logstash
浏览 4
提问于2016-08-24
得票数 3
回答已采纳
2
回答
Kafka
生产者的java客户端示例,不接受KeyedMessage的send方法
、
我运行的是
kafka
2.9.1-0.8.2.1。我将libs/目录中提供的jars包含在
kafka
主目录中。现在我试着按照这里给出的来运行一个java生产者示例。下面是代码import
kafka
.producer.ProducerConfig;import
kafka
.producer.Producer; import scala.collection.Seq
浏览 2
提问于2015-03-23
得票数 3
回答已采纳
1
回答
-IV0版本后缀是什么意思?
我们没有在log.message.format.version文件中指定server.properties选项,因此我们希望它应该是
Kafka
版本(即0.10.2.0)。但是当我们尝试执行
Kafka
代理滚动升级时,我们注意到服务器日志中的log.message.format.version=0.10.2.0-IV0。-IV0
版本号
后缀是什么意思? 为什么log.message.format.version默认与卡夫卡版本不同?
浏览 0
提问于2017-10-23
得票数 4
1
回答
使用
Kafka
基本设置创建主题和发送消息的错误消息
、
、
我的卡夫卡
版本号
是: 0.9.0.1,谢谢你的帮助。attrs': {'id': category, '_': datetime.utcnow().isoformat()}})) File "C:\Python27\lib\site-packages\
kafka
\producer\simple.py", line 36, in
浏览 4
提问于2016-04-21
得票数 0
7
回答
kafka
NoClassDefFoundError
kafka
/
Kafka
、
、
我已经从
Kafka
下载页面下载了Apache
Kafka
。我已经把它解压缩到/opt/apache/installed/
kafka
-0.7.0-incubating-src了。说您需要启动zookeeper,然后通过运行以下命令启动
Kafka
:我使用的是单独的Zookeeper当我按照快速入门页面中的说明运行
Kafka
浏览 6
提问于2012-05-04
得票数 16
回答已采纳
1
回答
如何从Spark结构化流中获取
Kafka
输出中的批ID
、
、
、
当我将这些输出到
Kafka
时,我需要知道哪一批是最新的--因此需要批号。我认为forEachBatch可以得到我所需要的东西,但不幸的是,我无法访问Spark2.4。OutputMode.Update())我想做这样的事 .format("
kafka
") .option("
kafka
.bootstrap.
浏览 0
提问于2019-09-17
得票数 0
回答已采纳
1
回答
Kafka
生产者-消费者无法生产/消费avro数据
、
、
、
我编写了一个
kafka
-producer代码来生成avro数据,但是它显示了在序列化数据时出现的以下错误: package com.perfaware.
kafka
01; import com.example.Customer; import io.confluent.
浏览 0
提问于2018-10-31
得票数 0
2
回答
我们能用钥匙从卡夫卡那里得到价值吗?我们如何在卡夫卡信息中传递标题?
我刚刚开始对
Kafka
的探索,我无法理解
kafka
中什么是键值的需要,因为我们也可以直接发送消息,像JMS这样的单个字符串。通过指定键可以从记录中获取值吗?
浏览 3
提问于2019-09-22
得票数 0
回答已采纳
1
回答
无法使用docker启动
Kafka
实例
、
:
KAFKA
_ZOOKEEPER_CONNECT: zookeeper:2181
KAFKA
_LISTENER_SECURITY_PROTOCOL_MAP
KAFKA</em
浏览 14
提问于2021-10-27
得票数 1
1
回答
无法将spring引导生成器应用程序与
kafka
汇合主题连接起来
、
、
、
获取以下eeror- org.springframework.
kafka
.KafkaException:发送失败;嵌套异常是60000 ms后元数据中不存在的org.springframework.
kafka
.KafkaException
浏览 5
提问于2022-10-03
得票数 0
回答已采纳
2
回答
如何运行多个卡夫卡经纪人使用码头-撰写?
、
、
KAFKA
_BROKER_ID: 1
KAFKA
_ADVERTISED_HOST_NAME:
kafka
KAFKA
_ZOOKEEPER_CONNECT: zookeeper_local_dev:2181
KAFKA
_LISTENERS: INTERNAL://
kafka
:9092
KAFKA
_ADVERTISED_LISTENERS: INTE
浏览 21
提问于2021-12-08
得票数 0
2
回答
EmbeddedKafka不工作导致Scala错误
、
、
=earliestspring.
kafka
.bootstrap-servers=${spring.embedded.
kafka
.brokers<init>(EndPoint.scala:32) at
kafka
.server.Defaults$.<init>(K
浏览 0
提问于2019-11-19
得票数 3
回答已采纳
1
回答
使用
kafka
和cassandra进行事件来源的类别预测
、
、
对如何做到的简单介绍: 1.1当它收到一个命令时,它会加载聚合的所有事件,并对每个事件重放聚合事件处理程序,以使聚合达到当前状态事件被标记为聚合的
版本号
--从新聚合的版本0开始,从而使预测成为可能。此外,它还将事件发送到另一个主题(用于投影目的)。我知道EventStore对这个内置的支持
浏览 0
提问于2019-08-06
得票数 0
回答已采纳
3
回答
KEYSTORE.JKS存在失败-与代码1 #662 -汇合卡夫卡一起退出
、
、
、
、
我正在尝试配置ssl以汇合
kafka
对接平台,并在开始说命令/usr/local/bin/dub路径/etc/
kafka
/机密/
kafka
.server.keystore.jks存在失败!: zookeeper1:2181
KAFKA
_LOG4J_LOGGERS: "
kafka
.controller=INFO,
kafka
.producer.async.DefaultEventH
浏览 2
提问于2018-12-29
得票数 5
3
回答
Kafka
在Docker和Spring Producer中的应用
、
、
、
我正在尝试在Docker和Spring上配置
Kafka
。 container_name: zookeeper ports:
kafka
: image: wurstmeister/
kafka</
浏览 1
提问于2020-06-26
得票数 1
2
回答
kafka
docker停留在配置上,不能在mac上工作
、
、
我正在尝试在docker上使用
kafka
。但是当运行docker compose时,
kafka
只是停留在配置模式上,而不是指示已经在运行。我为
kafka
主题做了列表,但它不工作或没有响应。
kafka
: container_name:
kafka
- 9092:9092 expose响应:
kafka
| [Configuring]
浏览 196
提问于2021-04-19
得票数 1
1
回答
在将
Kafka
集群与Spring引导和Apache Camel连接时获得SSL异常
、
、
、
我的要求是通过SSL将
Kafka
主题与Spring和Apache连接起来,为此,我编写了以下代码,但我面临一个错误,如sun.security.validator.ValidatorException:(){ store.setResource("
kafka
.client.truststore.jksthis path to point to your truststore/keysto
浏览 3
提问于2020-10-21
得票数 0
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
匹配版本号
版本号大小比较
gulp 添加版本号
豆瓣查看版本号教程
Kafka权威指南(一):初识Kafka
热门
标签
更多标签
云服务器
ICP备案
实时音视频
对象存储
云直播
活动推荐
运营活动
广告
关闭
领券