strimzi实战之二:部署和消息功能初体验
5发布于 2024-04-08
欢迎访问我的GitHub 这里分类和汇总了欣宸的全部原创(含配套源码):https://github.com/zq2599/blog_demos 本篇概览 本篇是《strimzi实战》系列的第二篇,前文完成了介绍和准备工作,是时候体验strimzi的核心功能了:发送和接受kafk...
阅读(1948)赞 (0)
发布于 2024-04-08
欢迎访问我的GitHub 这里分类和汇总了欣宸的全部原创(含配套源码):https://github.com/zq2599/blog_demos 本篇概览 本篇是《strimzi实战》系列的第二篇,前文完成了介绍和准备工作,是时候体验strimzi的核心功能了:发送和接受kafk...
阅读(1948)赞 (0)
发布于 2023-09-08
强类型语言和弱类型语言的区别 强类型语言:强类型语言也称为强类型定义语言,是一种总是强制类型定义的语言,要求变量的使用要严格符合定义,所有变量都必须先定义后使用。Java和C++等语言都是强制类型定义的,也就是说,一旦一个变量被指定了某个数据类型,如果不经过强制转换,那么它就永远...
阅读(1890)赞 (0)
发布于 2023-04-17
【进程间通信】常用方式汇总 在系统中,随着我们的进程越来越多,难免不同进程之间要互相传输一些数据,那么这个时候该怎么办呢? 下面主要简单了解一下,进程间通信(InterProcess Communication,IPC)的几种实现方式! 1、管道模型 管道模型与软件生命周期模型—...
阅读(2592)赞 (0)
发布于 2023-04-14
欢迎访问我的GitHub 这里分类和汇总了欣宸的全部原创(含配套源码):https://github.com/zq2599/blog_demos 关于strimzi strimzi是一个开源项目,已加入了CNCF,官网地址:https://strimzi.io/ 借助strimz...
阅读(1772)赞 (0)
发布于 2023-04-11
目录 一、背景 二、流程 三、案例 1.flink sql读取 Kafka 并写入 MySQL source sink insert 2.flinksql读kafka写入kudu source sink insert 四、注意点 1.断点续传 2.实时采集 3.回溯问题 2.实时...
阅读(1031)赞 (0)
发布于 2023-04-04
flink sql 模式代码demo (Java) (使用flink sql 进行流式处理注意字段的映射) 官方文档类型映射 import com.alibaba.fastjson.JSON; import org.apache.flink.streaming.api.datas...
阅读(916)赞 (0)
发布于 2022-11-22
今天也要努力学习 flume与kafka是同级的一个消息传输通道:但是有各自的定位 1:kafka定位消息队列,它可以有许多的生产者和消费者,并可以共享一个主题topic队列。而flume是定位数据传输,相比下,flume是一个专用工具被设计为旨在往HDFS,HBASE发送数据。...
阅读(2871)赞 (0)
发布于 2022-11-22
Kafka的主要特点 Kafka是分布式发布-订阅消息系统。它最初由LinkedIn公司开发,之后成为Apache项目的一部分。Kafka是一个分布式的,可划分的,冗余备份的持久性的日志服务。它主要用于处理活跃的流式数据。 kafka的主要特点: 同时为发布和订阅提供高吞吐量。据...
阅读(1118)赞 (0)
发布于 2022-11-14
前言 消息队列是在工作中作为服务解耦和消息推送等各种场景的应用中使用的组件,常用的队列组件有 ActiveMQ RabbitMQ RocketMQ Kafka 消息队列主要有2种模式,点对点模式跟发布/订阅模式 点对点模式 点对点模式就是在消息队列离的消息只能让一个消费者消费,也...
阅读(2753)赞 (0)
发布于 2022-11-08
工作中因为各种原因,topic中消息堆积的太多或者kafka所在磁盘空间满了等。可能需要彻底清理一下kafka topic。 cd /opt/kafka/kafka_2.10-0.10.2.2/bin 列出所有topic: ./kafka-topics.sh –zookeeper...
阅读(2347)赞 (0)