腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
Kafka
--
在
Java
中
收听
话题
还有
什么
比
poll
()
更好
的
选择
呢
?
java
、
apache-kafka
、
kafka-consumer-api
我正在尝试用
Java
创建一个消费者客户端。我意识到
poll
()函数被贬低了。听卡夫卡的
话题
有
什么
替代方案?我
的
代码: KafkaConsumer< String, UserSegmentPayload > kc = new KafkaConsumer<>(props2);while (true) { ConsumerRecords<String, UserSegm
浏览 32
提问于2020-01-28
得票数 5
回答已采纳
1
回答
还有
什么
比
在
Python
中
手动索引
更好
的
选择
呢
?
python
、
loops
、
for-loop
、
iteration
、
sublist
我是python
的
初学者。目前,我正致力于用嵌套列表
中
的
数据自动填充网页字段。但是,
在
处理更长长度
的
嵌套列表
的
情况下,比手动写下项目索引
更好
的
选择
是
什么
?谢谢
浏览 7
提问于2019-11-09
得票数 0
1
回答
卡夫卡服务器可以强制消费者属性吗?
apache-kafka
、
kafka-consumer-api
我是卡夫卡世界
的
新手。我可以
在
Java
中
设置
kafka
使用者,并且可以看到使用者API允许我设置使用者属性。properties.put(ConsumerConfig.MAX_
POLL
_INTERVAL_MS_CONFIG,2000);这对我来说很好我还在
kafka
服务器上看到一个名为consumer.properties
的
文件。我认为,如果我将max.
poll</e
浏览 6
提问于2019-11-18
得票数 2
回答已采纳
1
回答
生成“假”流数据。卡夫卡
java
、
apache-kafka
、
apache-flink
、
stream-processing
、
event-stream-processing
我试图生成流数据,以模拟在不同
的
时间范围内接收两个值( Integer类型)
的
情况,使用时间戳和
Kafka
作为连接器。我应该直接从卡夫卡得到数据吗?如果是的话,最好
的
方法是
什么
?或者,如果我把Flink制作出来
的
数据作为一个制作人,发送给
Kafka
,然后用F
浏览 2
提问于2018-08-20
得票数 2
1
回答
当处理较低时,
Kafka
用户轮询超时
apache-kafka
、
kafka-consumer-api
Kafka
broker版本: 2.6.2
Kafka
Java
apache client: 3.0.0consumer
poll
每个事件
的
处理时间大约为60 is。max.
poll
.interval.ms设置为默认
的
5分钟,max.
poll
.records=500也是。我记录了公制
的
time_between_
浏览 16
提问于2022-10-09
得票数 0
1
回答
卡夫卡消费者吐露设定max.
poll
.interval.ms大于request.timeout.ms
的
负面影响是
什么
?
java
、
apache-kafka
、
kafka-consumer-api
根据
Kafka
文件; 这些使用会产生
什么
负面影响?卡夫卡
的
文档<
浏览 1
提问于2019-02-22
得票数 4
回答已采纳
2
回答
如何通知消费者
在
Kafka
中
创建了新
的
topic?
apache-kafka
、
sarama
我
的
Kafka
消费者
的
主要责任是抓取我们
在
Kafka
中
的
任何日志/记录/消息,并将它们存储到数据库
中
。假设我
的
消费者正在积极消费dogs和cats主题,并且一切正常,现在有一种新
的
动物进入商店,并且
在
Kafka
集群中生成了一个新
的
主题。如何通知我
的
消费者添加了新
的
主题?我有两个建议,我想看看你认为哪个
浏览 2
提问于2017-10-11
得票数 0
3
回答
如何制作卡夫卡
的
副标题
redis
、
apache-kafka
、
apache-storm
我现在使用
的
是像'Sports_Football','Sports_Handball'...这样
的
主题这不是真正
的
功能,因为当我们需要时,当我们想要
的
主题‘体育’与所有的潜艇,我们需要查询所有的主题为它那么,有
什么
更好
的
方法吗?
浏览 0
提问于2018-02-14
得票数 0
回答已采纳
1
回答
Flink SQL不遵守“table.exec.source.空闲-超时”设置
apache-kafka
、
apache-flink
、
flink-sql
然而,没有水印
的
进展。
还有
什么
我可以检查
的
来测试这个设置? 我们正在运行
浏览 3
提问于2021-10-26
得票数 0
回答已采纳
1
回答
为
什么
Kafka
的
吞吐量
比
Redis高?
apache-kafka
、
redis
、
messagebroker
研究表明,与redis相比,当
Kafka
和redis都充当消息代理时,
Kafka
在
每秒
的
msgs数和每秒传输
的
mbs数方面都有
更好
的
吞吐量。最近一项名为“实时流处理管道
中
数据摄取平台
的
比较”
的
研究表明,对于1kB
的
有效负载,
kafka
可以处理
的
请求量是redis
的
3倍。 到底是
什么
让
Kafka
作为消息代理<em
浏览 8
提问于2021-10-14
得票数 0
3
回答
KAFKA
和SSL :
java
.lang.OutOfMemoryError:
KAFKA
SSL集群上使用
KAFKA
主题命令时
的
Java
堆空间
ssl
、
apache-kafka
、
apache-kafka-security
) at org.apache.
kafka
.common.network.Selector.
poll
(Selector.
java
:483) at org.apache.
kafka
.clients.NetworkClient.
poll
(NetworkClient.
java
浏览 0
提问于2019-10-03
得票数 10
回答已采纳
1
回答
我们如何使用从多个来源
的
火花流?例如,首先从HDFS获取数据,然后使用
Kafka
的
流
mysql
、
apache-spark
、
hadoop
、
apache-kafka
、
spark-streaming
我
在
MySQL上有5000万行事务数据,我想报告这些数据。我想把数据转储到HDFS
中
。现在,数据每天都在DB中出现,我正在为新
的
数据添加
KAFKA
。我想知道如何组合多个源数据并进行实时分析(延迟1-2分钟是可以
的
),并保存这些结果,因为未来
的
数据需要先前
的
结果。
浏览 3
提问于2022-08-27
得票数 0
1
回答
使用Flowable.generate RxJava处理错误
java
、
apache-kafka
、
rx-java
、
kafka-consumer-api
、
reactive-streams
我正在使用Flowable.generate构建一个
Kafka
consumer Flowable,下面是我
的
实现import org.apache.
kafka
.clients.consumer.KafkaConsumer; import
java
.util.Properties封装在一个try-catch
中
。我
的
疑问是
浏览 12
提问于2021-06-06
得票数 0
1
回答
Kafka
消费者属性从主题
的
开头开始
scala
、
apache-kafka
、
kafka-consumer-api
、
avro
我正在尝试编写一个
Kafka
消费者,以便从一开始就使用消息。我可以
在
控制台消费者中使用-- from - same来做同样
的
事情 但是我
在
JAVA
API
中
找不到相应
的
属性。") consume
浏览 16
提问于2020-04-06
得票数 1
回答已采纳
1
回答
星火(直接)流
的
自然替代品是星火结构化流还是卡夫卡流?
apache-spark
、
apache-kafka
、
spark-streaming
、
apache-kafka-streams
、
spark-structured-streaming
现在取消了Spark流
的
Direct (我们目前有2.3.2版本),并且我们最近向我们
的
项目添加了汇合平台(附带了
Kafka
2.2.0),我们计划迁移这些应用程序。
什么
是我们
的
火花流应用程序
的
自然替代?我们应该迁移到火花结构化流,或者更确切地说是卡夫卡流吗? 我个人对这两个框架没有任何经验,但在我看来,结构化流似乎是自然
的
选择
。我们
的
代码库主要是用Scala编写
的
,它也可以用于结构化API。
Kafka</e
浏览 4
提问于2020-02-19
得票数 0
回答已采纳
1
回答
Kafka
:民意测验
中
的
反序列化问题
apache-kafka
、
kafka-consumer-api
、
confluent-platform
为了
更好
地了解平台,我从几天以来一直
在
玩卡夫卡
的
合流版本。对于发送到一个主题
的
一些格式错误
的
avro消息,我得到了一些序列化异常。(我们
在
模式注册表
中
启用了一个选项,这样您就可以向topic发送任何消息,模式注册表每次都会生成一个新版本
的
模式,如果关闭,我们也可以关闭。)现在,由于这个one坏消息,
poll
()
在
序列化问题上失败了。它确实给出了它失败
的
偏移量,我可以使用sound ()传递偏移量,但
浏览 2
提问于2017-05-12
得票数 5
回答已采纳
10
回答
为
什么
在
java
中有两种使用线程
的
方法?
java
、
multithreading
、
inheritance
、
interface
我知道
在
java
中有两种使用线程
的
方法: 但为
什么
有两种方式--为
什么
不只是一种?如果实现Runnable是一种
更好
的
方法,为
什么
还有
另一种
选择
? 只有一个
选择
会有
什么
问题?
浏览 8
提问于2013-06-26
得票数 11
回答已采纳
3
回答
Broker (
Kafka
和RabbitMQ)
rabbitmq
、
apache-kafka
在
讨论卡夫卡和RabbitMQ
的
区别时,“哑巴经纪人”和“智能经纪人”
在
与消费者
的
互动
中
不断出现。卡夫卡被描述为有一个愚蠢
的
经纪人,而RabbitMQ据说有一个聪明
的
经纪人/愚蠢
的
消费者模型。这到底是
什么
意思?我熟悉卡夫卡
的
基础知识,并对RabbitMQ有更多
的
了解。然而,RabbitMQ
的
哪些功能使经纪人
比
卡夫卡更聪明
呢
?
浏览 5
提问于2017-08-28
得票数 11
2
回答
在这种情况下使用Apache有意义吗?
apache-kafka
、
messaging
、
apache-kafka-streams
、
apache-kafka-connect
所以他们
中
的
一个会得到问题,然后做一些事情,然后改变这个问题
的
状态。其他可能涉及这一问题
的
应用程序应该获得新
的
信息。这种情况一直持续到问题达到最终结束状态为止。问题在于必须映射问题,因为这些应用程序并不都支持相同
的
数据格式。 谢谢你
的
建议
浏览 2
提问于2017-10-11
得票数 1
回答已采纳
1
回答
将对象推送到webservice - ForkJoinPool正确方法
java
、
concurrency
、
parallel-processing
、
fork-join
我有一个需要推送到不同need服务
的
对象列表。我想比喻一下这一点。现在我想知道ForkJoinPool是否是正确
的
方法?因为这些任务不是递归
的
,所以我不确定。另一方面,我听说ForkJoinPool
的
性能
比
Executor服务要好。
浏览 1
提问于2015-04-16
得票数 0
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
kafka之consumer
2018数据分析、数据科学以及机器学习领域顶级工具的排名与趋势
说说 MQ之Kafka(二)
关于Kafka java consumer管理TCP连接的讨论
Kafka源码深度解析-序列2-Producer-Metadata的数据结构与读取、更新策略
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券