技术标签： big data
在linux下载pulsar安装包 wget https://archive.apache.org/dist/pulsar/pulsar-2.8.1/apache-pulsar-2.8.1-bin.tar.gz
解压缩 tar xvfz apache-pulsar-2.8.1-bin.tar.gz
启动 ./bin/pulsar standalone
后台启动 nohup ./bin/pulsar standalone &
报错 10:36:21.059 [main] ERROR org.apache.pulsar.zookeeper.LocalBookkeeperEnsemble - Exception while instantiating ZooKeeper
java.net.BindException: 地址已在使用
检查端口 2181
netstat -tunlp 检查目前所用的所有端口
netstat -tunlp | grep 2181 检查2181端口是否使用
fuser -v -n tcp 2181 检查占用2181端口的程序及进程
kill -9 杀死对应的pid，再重新启动pulsar即可
./pulsar-client produce my-topic --messages "-----hello pulsar-------" # 生产一条消息
./pulsar-client consume my-topic -s "-----hello pulsar-------" # 消费一条消息
修改IP和端口，让其它机器访问
./pulsar-client produce my-topic --messages “-----hello pulsar-------”
Policies not found for fl-tenant/fl-algorithm namespace
org.apache.pulsar.client.api.PulsarClientException$BrokerMetadataException: Policies not found for fl-tenant/fl-algorithm namespace
./pulsar-admin tenants create fl-tenant
./pulsar-admin namespaces create fl-tenant/fl-algorithm
Pulsar 的管理可以通过LIC命令行，REST api 、JAVA api管理
以下介绍使用LIC命令行 (pulsar2.4.2上测试)
1 租户
查看有哪些租户(public 是系统默认的租户)
$ pulsar-admin tenants list
创建租户
$ pulsar-admin tenants create my-tenant
删除租户
$ pulsar-admin tenants delete my-tenant
2 命名空间
查看指定租户下边的命名空间
$ pulsar-admin namespaces list test-tenant
创建指定租户命名空间
$ pulsar-admin namespaces create test-tenant/test-namespace
删除指定租户命名空间
$ pulsar-admin namespaces delete test-tenant/test-namespace
#include #include #include #include #pragma comment(lib, "dwrite.lib")#pragma comment(lib, "d2d1.lib")HINSTANCE g_hinst;HWND g_hwnd;ID2D1Factory * g_factory;ID2D1HwndRenderTarget * g_render
这里讲述一些初学者学习C51的一些误区和注意事项。高手的特别应用不包括在内。1)C忌讳绝对定位。常看见初学者要求使用_at_,这是一种谬误，把C当作ASM看待了。在C中变量的定位是编译器的事情，初学者只要定义变量和变量的作用域，编译器就把一个固定地址给这个变量。怎么取得这个变量的地址？要用指针。比如unsigned char data x;后，x的地址就是&x,你只要查看这个参数，就可以在...
/** * hex字符串转出字符串 *TODO *@param s *@return * @throws UnsupportedEncodingException */ public static String hexToString(String s) { byte[] bytes =
1. 找源码，在hisdk 里面就有zlib 的源码：zlib-1.2.8.tar.gz2. 解压，然后：cd zlib-1.2.8 3. ./configure --prefix=/work/opensource/zlib/zlib-1.2.8/_install ,然后修改MakefileCROSS=arm-hisiv500-linux-CC=$(CROSS)gccL
文章目录安装相关库原理简述代码效果实现今天教大家一个有趣的玩法，如何利用Python+opencv3实现简单的手势识别。当然网上也有相关教程，但绝大多数给出的代码拿来之后你是不能直接用的，这对于拿来主义的同学来说简直太“禽兽”了。所以今天我也会给出所有代码，只要配置好环境就可以运行。话不多说接下来就进入正题。安装相关库这个安装库的重要性就不用我多说了，但凡是想直接用人家的代码，就要安装人家运行所需的全部库。pip install opencv-pythonpip install opencv
整理不易，冲冲冲……后期继续更YUVPlayer下载地址：http://www.yuvplayer.com/YUV 文件下载地址：http://trace.eas.asu.edu/yuv/index.html注意：用YUVPlayer播放时请记住下载视频对应的长和宽的数值，播放时需要自己手动填入，否则会出现播放不正确的情况。...
使用getIdentifier()获取资源Idint i= getResources().getIdentifier("icon", "drawable", getPackageName()) ;if(i>0) {Log.i("aa","aa");}else {Log.i("vbv","aa");}或者int...
代码主要部分： val df = kafkaReadStream(spark, KAFKA_INIT_OFFSETS, KAFKA_TOPIC) .option("maxOffsetsPerTrigger",1000)//限流:对每个触发器间隔处理的最大偏移量的速率限制。指定的偏移量总数将按比例划分到不同卷的topicPartitions上。 .option("fetchOffset.numRetries",3)//尝试次数 .option("failOnDa
using System;using System.Collections.Generic;using System.Drawing;using System.Linq;using System.Web;using System.Web.Mvc;using Gma.QrCodeNet.Encoding;using Gma.QrCodeNet.Encoding.Windows.Rend...
#问题：nginx部署的vue项目中接入了第三方接口 在IE浏览器中出现了 Access-Control-Allow-Headers 列表中不存在请求标头 x-access-token。 其他浏览器正常#解决：在nginx中配置反向代理解决跨域
sql server死锁 In this article, we will talk about the deadlocks in SQL Server, and then we will analyze a real deadlock scenario and discover the troubleshooting steps. 在本文中，我们将讨论SQL Server中的死锁，然...
2.4; s+ v0 B. B. W1 P' ]( j基金管理（资金预算）上一章介绍的是资金管理中的资金头寸管理，流动性预测和公司总部资金平衡。本章介绍的模块是管理资金预算的。由于本模块在公共部门（如政府等）是特别重要的模块，...