腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
首页
学习
活动
专区
工具
TVP
最新优惠活动
返回腾讯云官网
JavaEdge
关注公众号:JavaEdge,加入全国最大的后端交流群。
专栏作者
举报
2432
文章
2418148
阅读量
175
订阅数
订阅专栏
申请加入专栏
全部文章
java
编程算法
数据库
sql
spring
缓存
云数据库 SQL Server
其他
存储
云数据库 Redis
http
容器
微服务
网站
api
网络安全
分布式
linux
jvm
jdk
kafka
ide
数据结构
tomcat
node.js
数据
apache
servlet
面向对象编程
socket编程
https
文件存储
hashmap
javascript
tcp/ip
android
git
系统
大数据
压力测试
打包
xml
html
容器镜像服务
c++
unix
人工智能
rabbitmq
uml
python
安全
rpc
数据分析
dubbo
服务
机器学习
腾讯云测试服务
配置
json
github
maven
nginx
windows
负载均衡
自动驾驶
jar
spark
php
spring boot
负载均衡缓存
接口
开发
神经网络
开源
设计
深度学习
单片机
kubernetes
zookeeper
消息队列 CMQ 版
mvc
运维
客户端
mac os
react
mybatis
jdbc
集群
bash
scala
企业
服务器
管理
监控
连接
aop
null
对象
架构
访问管理
mongodb
hadoop
es
flink
面试
事件
系统设计
go
bootstrap
ajax
数据处理
db
部署
解决方案
线程
异常
mapreduce
任务调度
编程
并发
测试
队列
工作
日志
性能
异步
css
nosql
access
bash 指令
电商
渲染
serverless
shell
推荐系统
二叉树
迁移
mysql
netty
产品
程序员
注解
jquery
汇编语言
memcached
unicode
mq
png
redis
函数
框架
模型
同步
c 语言
ubuntu
云数据库 MongoDB
hive
sql server
dns
udp
gradle
系统架构
架构设计
mac
select
搜索
索引
统计
优化
费用中心
ios
图像处理
爬虫
ssh
erp
yum
scrapy
gcc
spring cloud
腾讯云开发者社区
Elasticsearch Service
channel
controller
web
流量
重构
对象存储
数据挖掘
lua
vue.js
centos
短信
babel.js
数据迁移
grep
kernel
微信
flutter
ascii
add
command
default
google
image
service
代理
工具
技巧
镜像
内存
网络
线程池
协议
研发
语法
原理
erlang
.net
硬件开发
搜索引擎
全文检索
云推荐引擎
数据安全
webpack
正则表达式
gui
npm
单元测试
hbase
processing
云计算
sdk
boot
bug
client
commit
data
dump
hystrix
key
semaphore
set
string
timeout
变量
插件
程序
定时任务
多线程
翻译
互联网
架构师
前端
权限
事务
算法
效率
源码
终端
主机
官方文档
tensorflow
actionscript
jsp
qt
oracle
postgresql
ruby on rails
eclipse
lucene/solr
TDSQL MySQL 版
SSL 证书
金融
express
自动化
html5
线性回归
自动化测试
cdn
数据可视化
nat
mqtt
虚拟化
性能测试
app
autowired
count
ddd
exception
filter
intel
interrupt
ip
iso
max
min
pipeline
process
queue
release
root
selector
time
wait
wifi
编译
表格
反射
服务端
行业
继承
计算机
教程
可视化
快捷键
浏览器
入门
调试
项目经理
响应式
性能优化
指针
字符串
区块链
iphone
ruby
中文分词
analyzer
专用宿主机
云直播
命令行工具
数据备份
日志数据
yarn
xslt & xpath
监督学习
asp
ftp
markdown
ddos
jenkins
小程序
sas
云数据仓库套件 sparkling
分类算法
服务网格
验证码
项目管理
asm
bigdecimal
binary
binding
bit
boolean
code
dao
deployment
double
download
editor
error
expression
gateway
getter
glib
gpu
guava
icon
innodb
instagram
interface
io
java8
join
jta
list
listener
metadata
myisam
nacos
object
prometheus
ps
security
send
server
session
setter
settings
state
stream
sudo
sum
synchronized
system
task
tcp
thread
version
virtualbox
web3
window
编码
博客
布局
操作系统
动态代理
工程师
函数式编程
后端
基础
集合
脚本
进程
开发环境
软件
设计模式
生命周期
视频
数组
图表
网络编程
响应式编程
序列化
异常处理
域名
最佳实践
云服务器
比特币
数字货币
xcode
vbscript
ecmascript
android studio
嵌入式
svn
struts
windows server
apt-get
批量计算
日志服务
NAT 网关
cci 持续集成
大数据处理套件 TBDS
大数据可视交互系统
大数据解决方案
lodash
devops
游戏
黑客
决策树
scikit-learn
lamp
hexo
迁移学习
物联网
nest
canvas
sdn
聚类算法
mvcc
utf8
ipv6
dart
接口测试
事件总线
大数据存储
数据湖
汽车
远程调试
admin
agent
amd
apollo
arguments
audit
authentication
authorization
autocomplete
azure
behavior
bottle
buffer
build
byte
caching
center
chatgpt
chrome
cicd
class
clickhouse
clone
cloud
collections
configure
coredump
countdown
cpu
cron
crud
dashboard
dataframe
debug
desktop
dockerfile
druid
dry
dsl
duration
edit
email
encoding
environment
file
filtering
flush
flux
for循环
free
function
gif
grafana
graph
handler
homebrew
hostname
im
import
init
instrumentation
int
integer
ioc
jetbrains
jira
jmeter
jtextfield
lag
lambda
limit
local
localhost
lock
logback
logging
lombok
manifest
map
member
memory
merge
message
minikube
module
monitor
mono
mutex
native
nested
office
olap
oop
partition
pic
ping
plugins
poi
polymorphism
pool
predicate
project
properties
provider
proxy
push
quartz
rdd
rebase
record
render
requests
return
scale
scope
scp
script
setstate
shadow
shift
shopify
size
sleep
soa
socket
space
super
swagger
synchronization
target
tcpdump
textfield
timestamp
title
tls
token
tomcat7
tomcat8
tools
translate
translation
trim
ui
union
vmware
void
volatile
vue3
wiki
wireshark
报表
编程语言
编辑器
并发编程
地图
动画
二进制
分布式锁
分布式系统
分页
高并发
高可用
工程化
工具类
公众号
后台
华为
加密
监控工具
兼容性
建站
开源框架
跨平台
路由
敏捷
命令行
排序
配色
容器技术
数据存储
数据类型
数据同步
数据中心
数学
通信
推送
网关
协程
性能监控
虚拟机
压缩
依赖注入
硬件
源码分析
源码阅读
云原生
状态机
组件化
OLTP
数据库优化
数据流
软件设计
搜索文章
搜索
搜索
关闭
图解Kafka Producer常用性能优化配置参数
缓存
kafka
客户端
配置
性能优化
涉及到消息发送是如何工作的,本节首先将罗列参数,做简单说明,然后再给出运作图,进一步阐述其工作机制。
JavaEdge
2024-01-03
189
0
实时数据系统设计:Kafka、Flink和Druid
kafka
flink
druid
数据
系统设计
对于使用批处理工作流的数据团队来说,要满足当今的实时需求并不容易。为什么呢?因为批处理工作流,从数据传递和处理到分析,涉及很多等待。
JavaEdge
2023-12-18
273
0
全网最全图解Kafka适用场景
存储
kafka
日志
数据
系统
消息系统被用于各种场景,如解耦数据生产者,缓存未处理的消息。Kafka 可作为传统的消息系统的替代者,与传统消息系统相比,kafka有更好的吞吐量、更好的可用性,这有利于处理大规模的消息。
JavaEdge
2023-11-25
129
0
Kafka Tool模拟数据发送
kafka
数据
📷 📷
JavaEdge
2023-03-31
899
0
金融业务如何高性能传输数据
编程算法
系统架构
kafka
金融
apache
券商发给交易所的订单数据属于事务数据。这里的事务指的是数据库事务(Transaction)。所以交易数据的传输需满足顺序正确性要求,既要保证顺序的正确性,也要保证消息处理的一次性。
JavaEdge
2022-12-30
442
0
关注专栏作者,随时接收最新技术干货
JavaEdge
华为软件开发工程师
关注
用户9163319
关注
用户3692821
关注
用户9625762
关注
kafka单条消息过大导致线上OOM,运维连夜跑路了!
kafka
linux
查看日志,发现Pro程序爆异常kafka.common.MessageSizeTooLargeException。
JavaEdge
2022-12-20
387
0
如何保证消息恰好被消费一次?
kafka
存储
因为业务逻辑从同步代码中移除,所以也要有相应队列处理程序处理消息、执行业务逻辑。随着业务逻辑复杂,会引入更多外部系统和服务,就会越来越多使用MQ,与外部系统解耦合以及提升系统性能。
JavaEdge
2022-11-30
336
0
Kafka是如何应用NIO实现网络通信的?
http
kafka
java
自动驾驶
Acceptor和Processor之间缓存SocketChannel newConnections队列,保证线程安全顺序。
JavaEdge
2022-11-30
291
0
【大厂消息队列】面试解析(2)-MQ选型
消息队列 CMQ 版
kafka
开源
rabbitmq
apache
方便可以修改源代码,而非一味地等待软件提供商猴年马月发布的下个版本解决。在知识产权下,使用开源的才可商用。
JavaEdge
2022-11-30
584
0
Kafka实战(3)-Kafka的自我定位
kafka
编程算法
分布式
apache
windows
Kafka对消息保存时根据Topic进行归类,发送消息者成为Producer,消息接受者成为Consumer,此外kafka集群有多个kafka实例组成,每个实例(server)称为broker。
JavaEdge
2022-11-30
367
0
消息队列面试解析系列(一)-消息队列(MQ)的意义
rabbitmq
apache
消息队列 CMQ 版
kafka
见名知义,消息队列主要就是用来发送和接收处理消息,但它的作用可不仅解决应用间通信问题。
JavaEdge
2022-11-30
1.4K
0
Kafka实战(1)-为何大厂都选择Kafka作为消息队列
kafka
rpc
java
编程算法
MQ是一组规范。 利用这组规范可以在不同系统间传递语义准确的消息,实现松耦合的异步式数据传递。
JavaEdge
2022-11-30
593
0
Kafka实战(7)-究竟该如何部署Kafka集群?
kafka
linux
java
windows
生产环境需考量各种因素,结合自身业务需求而制定。看一些考虑因素(以下顺序,可是分了顺序的哦)
JavaEdge
2022-11-30
386
0
Kafka实战(2)-Kafka消息队列模型核心概念
消息队列 CMQ 版
数据库
sql
kafka
Kafka发布订阅的对象是主题(Topic),可为每个业务、每个应用甚至是每类数据都创建专属的主题。
JavaEdge
2022-11-30
342
0
Kafka实战(四) -Kafka门派知多少
kafka
apache
专用宿主机
大数据
linux
Kafka不是一个单纯的消息引擎系统,而是能够实现精确一次(Exactly-once)处理语义的实时流处理平台
JavaEdge
2022-11-30
372
0
Flink实战(八) - Streaming Connectors 编程
kafka
flink
大数据
文件存储
存储
Flink内置了一些基本数据源和接收器,并且始终可用。该预定义的数据源包括文件,目录和插socket,并从集合和迭代器摄取数据。该预定义的数据接收器支持写入文件和标准输入输出及socket。
JavaEdge
2022-11-30
1.9K
0
Flink实战(八) - Streaming Connectors 编程
kafka
flink
大数据
文件存储
存储
Flink内置了一些基本数据源和接收器,并且始终可用。该预定义的数据源包括文件,目录和插socket,并从集合和迭代器摄取数据。该预定义的数据接收器支持写入文件和标准输入输出及socket。
JavaEdge
2022-11-30
1.9K
0
突破Java面试(18)-消息队列面试技巧总结
编程算法
java
es
kafka
其实如果我是面试官的话,我如果感觉你都把刚才那些问题都答出来了,我可能会继续刨根问底,深挖,问你,直到把你给问倒
JavaEdge
2022-11-30
258
0
RabbitMQ面试必备知识点及实战(二)-核心概念
rabbitmq
消息队列 CMQ 版
kafka
tcp/ip
java
开源的消息代理和队列服务器,通过普通协议在完全不同的应用间共享数据,使用Erlang语言编写,并且基于AMQP协议。
JavaEdge
2022-11-30
314
0
突破Java面试(9)-如何保证消息队列的顺序性
rabbitmq
kafka
数据库
云数据库 SQL Server
sql
应该得保证消息按照顺序执行的吧! 不然本来是:增加->修改->删除 你楞是换了顺序给执行成:删除->修改->增加 全错!!!
JavaEdge
2022-11-30
288
0
点击加载更多
社区活动
Python精品学习库
代码在线跑,知识轻松学
点击查看
【玩转EdgeOne】征文进行中
限时免费体验,发文即有奖~
立即参加
博客搬家 | 分享价值百万资源包
自行/邀约他人一键搬运博客,速成社区影响力并领取好礼
立即体验
技术创作特训营·精选知识专栏
往期视频·干货材料·成员作品·最新动态
立即查看
领券
问题归档
专栏文章
快讯文章归档
关键词归档
开发者手册归档
开发者手册 Section 归档