kafka
-
Java实现Kafka生产者消费者代码实例
Kafka的结构与RabbitMQ类似，消息生产者向Kafka服务器发送消息，Kafka接收消息后，再投递给消费者。[详细]
2020-12-23 11:03 分类：编程语言 -
docker快速搭建kafka集群
1. 前言本文介绍如何在linux下利用docker快速搭建kafa单机集群2.项目地址：https://github.com/wurstmeister/kafka-docker3.环境安装3.1 安装docker-compose1）安装Python3参考Python系列2）安装相关libUbuntu: sudo apt install -y ...[详细]
2020-11-01 12:18 分类：Linux -
-
Python confluent kafka客户端配置kerberos认证流程详解
kafka的认证方式一般有如下3种： 1.SASL/GSSAPI 从版本0.9.0.0开始支持 2.SASL/PLAIN 从版本0.10.0.0开始支持[详细]
2020-10-13 10:25 分类：Python -
由Flink与Kafka实践探究Kafka的两个问题
笔者在某次实践过程中，搭建了一个Flink监控程序，监控wikipedia编辑，对编辑者编辑的字节数进行实时计算，最终把数据sink到kafka的消费者中展示出来，监控程序本身比较简单，只要在程序中指定好WikipediaEditsSource源并配置好sink与kaf...[详细]
2020-09-29 13:07 分类：Linux Centos7.6部署kafka2.5.0+zookeeper3.6.1集群
集群规划：三台服务器各部署一个kafka集群节点、一个zookeeper集群节点。服务器zookeeper角色kafka角色ipnode1masterbroker:0192.168.146.199node2followerbroker:1192.168.146.200node3followerbroker:2192.168.146.201PS：命令行开头为...[详细]
2020-09-28 16:27 分类：Linuxkafka数据自动清理失效
kafka只会回收上个分片的数据，所以log.roll.mslog.retention.hours要设置成一样的# Licensed to the Apache Software Foundation (ASF) under one or more# contributor license agreements. See the NOTICE file distributed with# t...[详细]
2020-09-10 12:27 分类：Linux-
掌握这10个常见的Kafka经典面试题，你还怕被问消息中心吗？
最近工作中呢，频频用到消息中心，包括异步转同步的功能，分布式收集日志信息等功能，在面试中也常会问到候选人关于消息中心的知识点，但大多数程序员，尤其是工作两三年的，虽然平时工作中都有用到消息中心，但都总是不能够说明白其中的...[详细]
2020-09-10 09:45 分类：编程语言 -
加载中,请稍侯......