首页
博客
源码
资源
博客
源码
写文章
发布博客
发布资源
登录
X
kafka
相关资讯
热门
最新
代码人生
01-01 08:00
代码人生
Kafka的监听地址配置实例详解
Kafka的监听地址配置实例详解,这篇文章主要给大华介绍了关于Kafka监听地址配置的相关资料,文中通过实例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下有时我们会碰到网络是通畅的,但却连不上Kafka,特别是在多网卡环境或者云环境上很容易出现,这个其实和Kafka的监听配置有关系。本文介绍监听相关的配置,目前监听相关的参数主要有下面几个:listenersa
159
代码人生
01-01 08:00
代码人生
kafka为什么有的消息的时间戳的值是-1(kafka消息顺序)
kafka为什么有的消息的时间戳的值是-1(kafka消息顺序),背景我在检索消息的时候,意外发现一些消息的时间值是-1,如下:而另外两条消息却有正常的时间。想找下相关原因,所以查阅了一下kafka官方文档,有了相关结论。官方说明kafka消息的格式有多个版本,在老版本中,是没有时间戳这个字段的。官方文档地址:ApacheKafka按照文档说明,在0.11之前的版本中,消息的发送和存储都是在消息集
99
代码人生
01-01 08:00
代码人生
Kafka介绍及设计原理详解(kafka原理图)
Kafka介绍及设计原理详解(kafka原理图),kafka基本概念kafka是一个分布式,分区的消息服务。名称解释broker消息中间件处理节点,一个Kafka节点就是一个broker,一个或者多个Broker可以组成一个Kafka集群topicKafka根据topic对消息进行归类,发布到Kafka集群的每条消息都需要指定一个topicproducer消息生产者,向Broker发送消息的客户端
163
代码人生
01-01 08:00
代码人生
kafka单排日记——zookeeper安装
kafka单排日记——zookeeper安装,前言公司的产品用kafka用的非常多,那没啥好说的了,学吧。一天学一点。套路相较于es又有所变化,es只要用的熟练,原理往后面放。kafka不行,对kafka原理的理解直接影响你的使用和对这个软件的想象力。所以,咱们的流程变为:软件安装-原理理解-框架整合-问题解决以及持续提升。那么这一篇,没啥好说的,就是狂安装软件了。为了接近正式的使用场景,直接装z
299
代码人生
01-01 08:00
代码人生
kafka如何保证有序性(kafka如何保证数据一致性)
kafka如何保证有序性(kafka如何保证数据一致性),kafka中的每个partition中的消息在写入时都是有序的,而且单独一个partition只能由一个消费者去消费,可以在里面保证消息的顺序性。但是分区之间的消息是不保证有序的。Kafka保证一个Partition内的消息的有序性Kafka分布式的单位是partition,同一个partition用一个writeaheadlog组织,所以
277
代码人生
01-01 08:00
代码人生
Kafka生产者分区策略(kafka分区的作用)
Kafka生产者分区策略(kafka分区的作用),前言查阅了一些资料和看了许多网上的文章,总觉得没有把Kafka生产者分区策略给讲明白,本篇将围绕以下问题步步深入来对文章进行展开。为什么需要生产者分区策略生产者分区策略有哪些不同分区策略有哪些优点和缺点如何进行自定义分区策略一、生产者发送消息流程说明(1)新建ProducerRecord对象,包含目标主题和要发送的内容,也可以指定键或分区;(2)发
480
代码人生
01-01 08:00
代码人生
kafka-topics.sh脚本详解
kafka-topics.sh脚本详解,通过脚本进行主题的管理,包括:创建主题、查看主题、修改主题、删除主题等操作。内部是靠kafka.admin.TopicCommand接收参数运行。[xuhaixing@xhx151~]$kafka-topics.sh--helpThistoolhelpstocreate,delete,describe,orchangeatopic.OptionDescrip
289
代码人生
01-01 08:00
代码人生
kafka、rabbitmq、redis区别,各自适合什么场景?
kafka、rabbitmq、redis区别,各自适合什么场景?,转载kafka、rabbitmq、redis区别,各自适合什么场景?-Kris-Q-博客园在应用场景方面RabbitMQRabbitMQ遵循AMQP协议,由内在高并发的erlanng语言开发,用在实时的对可靠性要求比较高的消息传递上,适合企业级的消息发送订阅,也是比较受到大家欢迎的。kafkakafka是Linkedin于2010年
149
代码人生
01-01 08:00
代码人生
kafka某个broker节点未启动造成无法选举leader
kafka某个broker节点未启动造成无法选举leader,问题描述:topic都是多分区,多副本,broker节点关闭后,由于某些情况,某个节点无法启动,其他节点都启动后,topic或部分分区仍不可用,造成无法选举leader1.创建topictopic:topic-demo023分区,3副本[xuhaixing@xhx151cluster]$kafka-topics.sh--zookeepe
179
代码人生
01-01 08:00
代码人生
kafka使用kerberos协议踩坑实录(kerberos协议的缺点)
kafka使用kerberos协议踩坑实录(kerberos协议的缺点),1,安装kdcdockerrun-d-p88:88/udp-p749:749/udpbeargiles/kdc-sandbox生成keytab参考:https://registry.hub.docker.com/r/beargiles/kdc-sandbox复制代码2,配置kafka服务启用kerberos认证config/
1118
«
1
2
3
4
5
6
7
8
9
10
11
»