活动
3、kafka重要概念介紹及示例
文章目录Apache Kafka系列文章一、概念1、Kafka重要概念1）、broker2）、zookeeper3）、 producer（生产者）4）、consumer（消费者）5）、consumer group（消费者组）6）、分区（P
Kafka 访问异常记录
1 [thrd:srvdb:9092/0]: srvdb:9092/0: Failed to resolve 'srvdb:9092':不知道这样的主机原因：Kafka服务器集群之间使用主机名解决方案：通过将服务器集群后台地
Kafka集群吞吐量测试（生产者和消费者）
测试Kafka集群的吞吐量，即为每秒钟最大可以生产多少条消息，以及每秒钟最大可以消费多少条消息。 在测试
Kafka生产者同步或者异步发送消息（保证数据不丢失）
参考文档：Usage — kafka-python 2.0.2-dev documentation 同步方式 示例代码： 运行结果：
Kafka Partition分发策略
今天突然
kafka运维之broker扩容
背景： 最近公司的3节点kafka集群，发现有2个节点所在的刀箱交换机有故障风险，会随机性的出现端口up/down的情况。 因此需要临时将这2个broker迁移出来，等交换机修复后再迁移回去。下面是实验模拟的整个过程（扩容+缩容）原先
Druid 使用 Kafka 将数据载入到 Kafka
将数据载入到 Kafka现在让我们为我们的主题运行一个生成器（producer），然后向主题中发送一些数据！在你的 Druid 目录中，运行下面的命令：在你的 Kafka 的安装目录中，运行下面的命令。请将 {PATH_TO_DRUID}
Flink测试kafka数据写入和打印出
Flink测试kafka数据写入和打印出
Kafka性能调优
Kafka的配置详尽、复杂，想要进行全面的性能调优需要掌握大量信息，这里只记录一下我在日常工作使用中走过的坑和经验来对kafka集群进行优化常用的几点。1.JVM的优化 java相关系统自然离不开JVM的优化。首先想到的肯定是Heap Si
Kafka存储在Zookeeper中的数据
Kafka存储在Zookeeper中的数据
Docker Kafka Linux安装教程
Docker Kafka Linux安装教程
kafka ksql && docker 安装试用
kafka ksql && docker 安装试用 备注： 使用docker 模式进行安装 1. 准备docker 环境（需要docker-compose） 2. 安装 kafa 以及ksql 3. 启动使用
Kafka
一、概念Kafka 是一种高吞吐量、分布式、基于发布/订阅的消息系统，最初由 LinkedIn 公司开发，使用 Scala 语言编写，目前是 Apache 的开源项目。broker：Kafka 服务器，负责消息存储和转发；topic：消息类
kafka zookeeper docker容器互联
kafka zookeeper docker容器互联
kafka-python消费者读取数据时自定义偏移量，自定义数据读取的顺序
kafka-python消费者读取数据时自定义偏移量，自定义数据读取的顺序
spring集成kafka运行时报错：Failed to construct kafka producer] with root cause
spring集成kafka运行时报错：Failed to construct kafka producer] with root cau
windows下运行kafka报错：‘wmic‘ 不是内部或外部命令，也不是可运行的程序
windows下运行kafka报错：'wmic' 不是内部或外部命令，也不是可运行的程序 解决方案，把 加入环境变量。
kafka报错：Exception in thread “main“ joptsimple.UnrecognizedOptionException: zookeeper is not a recogn
kafka创建主题topic报错：Exception in thread "main" joptsimple.Unrec
KafkaTemplate配置ProducerInterceptor|springboot整合kafka，配置自定义拦截器
实际开发中，可能需要多kafka发送的消息在发送前进行操作，比如按照某个规则过滤掉不符合要求的消息，或者屏蔽某些关键词，或者改变某些属性等等，都可以依托拦截器链来实现。自定义拦截器需要实现ProducerInterceptor接口，根据需要
热门文章
Kafka集群吞吐量测试（生产者和消费者）
2023-06-16 06:08:54
kafka报错：Exception in thread “main“ joptsimple.UnrecognizedOptionException: zookeeper is not a recogn
2023-04-13 09:31:18
KafkaTemplate配置ProducerInterceptor|springboot整合kafka，配置自定义拦截器
2023-03-02 10:21:35
Flink测试kafka数据写入和打印出
2023-05-30 07:51:14
kafka运维之broker扩容
2023-05-30 07:51:24
Druid 使用 Kafka 将数据载入到 Kafka
2023-05-30 07:51:14
- APP
