简介
该用户还未填写简介
擅长的技术栈
可提供的服务
暂无可提供的服务
kafka消费者数量如何增加
题目:kafka日志保存时间答案:kafka默认保存7天;生产环境建议3天
题目:kafka单条日志传输大小答案:kafka对于消息体的大小默认单条最大值是1M。但是在我们应用场景中,常常会出现一条消息大于1M,如果不对kafka进行配置,则会出现生产者无法将消息推送到kafka或者消费者无法去消费kafka里面的数据,这时我们就要对kafka进行如下配置:server.properties注意:message.max.bytes必须小于等于replica.fetch.m
题目:kafka消息数据积压,kafka消费能力不足怎么处理答案:1.提高生产者吞吐量(1)buffer.memory:发送消息的缓冲区大小,默认值是32m,可以增加到64m(2)batch.size:默认是16k。如果batch设置太小,会导致频繁网络请求,吞吐量下降;如果batch太大,会导致一条消息需要等待很久才能被发送出去,增加网络延时(3)linger.ms:这个值默认是0,意思是消息立
题目:kafka如何保证多分区之间的数据是有序的答案:提示:这里可以添加要学的内容例如:搭建 Java 开发环境掌握 Java 基本语法掌握条件语句掌握循环语句
题目:kafka分区数的设置答案:(1)创建一个只有1个分区的topic(2)测试这个topic的Producer吞吐量和consumer吞吐量(3)假设它们的值分别是Tp和Tc,单位可以是MB/s(4)然后假设总的目标吞吐量是Tt,那么分区数=Tt/min(Tp,Tc)例如:producer吞吐量=20m/s;consumer吞吐量=50m/s,期望吞吐量100m/s;分区数=100/20=5分