腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
在
Apache
Kafka
中
暂停
主题
之前
,
无法
获取
发布
的
旧
消息
java
、
apache
、
chat
在
Kafka
中
订阅Topic
之前
,如何
获取
所有
消息
都已
发布
?我使用
Kafka
2.12-2.3.0 Producer发送
消息
,Consumer接收
消息
。实际上,我正在使用
Kafka
在
java
中
构建一个聊天应用程序。但问题是,如果生产者
发布
了一些
消息
,而消费者后来订阅了,那么它就得不到这些
消息
。请给我一些建议。
浏览 15
提问于2019-09-14
得票数 0
1
回答
WSO2微集成器是否支持
Kafka
2.3.1入站端点从
Kafka
读取
消息
?
apache-kafka
、
wso2
、
wso2esb
、
wso2mi
“我正在做一个
Kafka
集成,我可以
发布
和读取
主题
中
的
消息
。我可以将
消息
发布
到
主题
,但
无法
使用入站终结点读取这些
消息
。当我查看WSO2文档时,他们建议使用非常
旧
的
Kafka
kafka
_2.9.2-0.8.1.1。我们不能将最新版本
的
Kafka
与Micro Integrator一起使用吗?请给我建议。”
浏览 12
提问于2020-01-04
得票数 1
2
回答
向
Kafka
发送关于动态创建
的
主题
的
消息
时出现错误LEADER_NOT_AVAILABLE
java
、
spring
、
spring-boot
、
spring-kafka
我正在尝试使用以下代码
在
动态创建
的
主题
上发送
消息
:public class KafkaMessageSender { }当我使用topic = 'somethingnew‘调用这个send方法时,我得到了下面的error,(有趣
的
是它可以发送一些
消息
,但对于很多人来说,它会
浏览 12
提问于2018-02-13
得票数 3
回答已采纳
2
回答
Logstash 5.1.1
kafka
输入不能提取
主题
中
的
现有
消息
elasticsearch
、
apache-kafka
、
logstash
、
apache-zookeeper
我有以下带有
kafka
输入
的
logstash配置
kafka
{ topics => ["codec => "json" doc_as_upsert => true }我面临
的</e
浏览 5
提问于2017-02-04
得票数 2
1
回答
在
成功提交当前消耗
的
偏移量
之前
,60万of
的
超时已过期。
apache-kafka
、
spring-batch
出于测试目的,我
在
Kafka
主题
上
发布
了5k条
消息
,并且
在
我
的
春季批处理应用程序
中
,每次迭代读取100条
消息
,它在完成
之前
运行约2小时。 原因和解决
浏览 2
提问于2021-09-28
得票数 2
2
回答
pubSubSource:重复使用相同
的
消息
两次
apache-kafka
、
apache-kafka-connect
、
google-cloud-pubsub
、
confluent-platform
描述部署
Kafka
和
Kafka
连接内容类型: application/
浏览 1
提问于2021-02-24
得票数 1
回答已采纳
1
回答
Apache
kafka
能否提供异步
消息
传递服务?
apache-kafka
、
kafka-consumer-api
、
kafka-producer-api
我打算使用Spring boot和webSocket以及
Kafka
实现一个聊天室,但是我需要知道
Kafka
是否提供了异步
消息
传递服务
浏览 2
提问于2019-07-02
得票数 0
1
回答
在
Spring boot
中
暂停
/启动
Kafka
流处理器
java
、
spring-boot
、
apache-kafka
、
spring-kafka
、
circuit-breaker
我将为
消息
实现一个断路器模式。基本要求是,如果微服务
无法
将
消息
发布
到
发布
主题
,则应停止接受来自其他
Kafka
主题
的
消息
。当
发布
主题
可用时,微服务应该开始接受来自其他
Kafka
主题
的
消息
。有没有办法
在
Spring boot
Kafka
Streams
中
实现这一
浏览 33
提问于2020-11-30
得票数 1
6
回答
Kafka
对实时数据
的
主要优势是什么?
分布式
、
大数据
在
我们
的
大数据时代,您
的
IT基础架构可能会受到各种来源数据涌入
的
影响。最重要
的
是,客户要求“实时”查看他们
的
数据,没有任何延迟时间,因此您
的
服务器需要快速处理和显示数据。
Kafka
是一个分布式流媒体平台,使公司能够创建实时数据源。Uber,Twitter,Airbnb,Yelp以及今天财富500强公司
中
超过30%
的
公司都在使用它。例如,通过集成各种数据,如喜欢,页面点击,搜索,订单,购物车和库存,
Kafka<
浏览 7035
提问于2018-09-14
3
回答
Apache
Kafka
是JMS
的
另一个API吗?
migration
、
apache-kafka
、
jms
Apache
Kafka
不是JMS
的
另一种实现吗 我正在我
的
应用程序中使用JMS+AMQ,并迁移到
Apache
Kafka
。我必须更改所有的JMS代码吗?
浏览 2
提问于2015-05-26
得票数 25
回答已采纳
1
回答
偏移量和分区-
Kafka
接收器处理器
apache-kafka
我们正在使用
kafka
Topology forward向
kafka
主题
发送记录。 我们
之前
使用了一个单独
的
生产者来
发布
消息
,并且我们能够
获取
消息
的
偏移量和分区。如何使用context.forward
获取
Kafka
Sink处理器发送
的
记录
的
偏移量和分区
浏览 0
提问于2017-11-01
得票数 0
5
回答
当卡夫卡复制品
中
的
一个倒下时会发生什么
apache-kafka
我有一个由2个
Kafka
代理组成
的
集群,以及一个具有复制因子2
的
主题
。如果其中一个代理死亡,我
的
制作人是否能够继续向这个退化
的
一个节点集群发送新
消息
?或者复制因子2需要2个活动节点,而
消息
将被拒绝?
浏览 8
提问于2016-08-17
得票数 3
回答已采纳
1
回答
如何从
kafka
中
删除
旧
消息
而不是最近
的
消息
python
、
amazon-web-services
、
apache-kafka
我正在试着从
kafka
中
删除
旧
的
消息
,它没有像预期
的
那样工作。我已经配置了
kafka
rentension.ms,log.cleanup属性也。但是它在5分钟后没有删除
旧
的
消息
。这是配置,
在
5分钟内,新
消息
也会
发布
,尽管
kafka
主题
中存在较
旧
的
记录。您能帮我解决这个配置
中
缺
浏览 6
提问于2020-09-02
得票数 1
1
回答
如何使用
Kafka
Java api检查消费者数据
apache-kafka
、
kafka-consumer-api
、
kafka-producer-api
这是我
的
消费者代码: props.put("group.id", "testgroup"); props.put("
kafka
.topic/
kafka
-server-
浏览 0
提问于2016-04-03
得票数 0
1
回答
如何优雅地处理由REST触发
的
由spring云流触发
的
Kafka
发布
失败
apache-kafka
、
spring-integration
、
spring-cloud-stream
、
spring-transactions
、
spring-cloud-stream-binder-kafka
我有一个场景,几条
消息
必须通过服务层
中
REST
的
触发器
发布
。 此服务还具有db操作(插入、更新)。这里
的
要求是,如果有网络问题导致
发布
者
无法
发布
,或者
kafka
broker不可用时,我们希望回滚所有东西,包括数据库,并通过API响应通知用户它失败了。根据我
的
理解,默认情况下,同一事务数据库将首先提交,然后由
kafka
跟踪,但我不确定
的
是,如果
kafka
没有提交,
浏览 5
提问于2021-07-25
得票数 0
3
回答
读取字段‘topic_metadata’时出错:读取大小为1139567
的
数组时出错,只有45个字节可用
apache-kafka
、
kafka-consumer-api
,试图从一个
主题
读取,但我得到一个奇怪
的
异常,我不能处理它。");bin/zookeeper-server-start.sh config/zookeeper.properties --启动
Kafk
浏览 3
提问于2016-06-02
得票数 8
回答已采纳
2
回答
如何冻结一个
主题
的
AVRO schema
的
新版本,从而拒绝不符合要求
的
消息
?
apache-kafka
、
avro
、
confluent-schema-registry
、
kafka-rest
使用Java Client producer,可以
在
发布
到
主题
之前
对
消息
进行微调以符合模式格式。使用
kafka
rest proxy,如果
消息
无法
用
kafka
avro模式版本反序列化,如何拒绝
消息
?这是为了防止不符合模式
的
客户端添加垃圾。我看到这个版本会自动升级到一个
主题
的
新模式。如何限制
消息
发布
到
主题
?这可
浏览 33
提问于2019-11-22
得票数 0
2
回答
Flume代理:将主机添加到
消息
中
,然后
发布
到
kafka
主题
hadoop
、
apache-kafka
、
flume
、
flume-ng
通过将
消息
发布
到
Kafka
主题
,我们开始整合应用程序
中
的
事件日志数据。虽然我们可以直接从应用程序写到
Kafka
,但我们选择将它作为一个通用问题来处理,并使用Flume代理。这提供了一些灵活性:如果我们想从服务器
获取
其他内容,我们只需跟踪不同
的
源并
发布
到不同
的
Kafka
主题
。,
消息
本身并没有指定生成它们
的
主机。如果我们
在<
浏览 4
提问于2015-11-16
得票数 4
回答已采纳
2
回答
Spring和
Kafka
-具有相同组ID
的
多个消费者-只有一个消费者收到
消息
spring-boot
、
apache-kafka
、
spring-kafka
我开始使用Spring Boot使用
Apache
Kafka
。我希望实现这样一个事实,即同一服务
的
两个实例以循环方式使用同一
主题
的
消息
。因此,实例1接收
主题
的
第一条
消息
,实例2
获取
第二条
消息
,实例1
获取
第三条
消息
。value-deserializer: org.
apache
.
kafka
.common.serialization.
浏览 1
提问于2020-09-13
得票数 2
4
回答
与
Apache
Pulsar相比,
Kafka
的
优点和缺点是什么
apache-kafka
、
apache-pulsar
雅虎开发了Pulsar,pub-sub
消息
系统,并使其开源。它现在是
Apache
的
孵化项目。因为
Kafka
也用于相同
的
目的。想知道,卡夫卡相对于脉冲星
的
主要正负点。
浏览 1
提问于2017-09-05
得票数 56
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Apache Kafka 3.0 发布,离彻底去掉ZooKeeper更进一步
Apache Kafka 2.0.0版本发布,多方面功能得到加强
Kafka入门&介绍part1
Apache Kafka 3.0.0持续更新共识机制KRaft,并着手清理旧支持与设置
CDC Debezium 介绍
热门
标签
更多标签
活动推荐
运营活动
广告
关闭
领券