www.1862.net > kAFkA 只能用jAvA监控吗

kAFkA 只能用jAvA监控吗

你的意思是kafka的生产和消费端可以用什么语言实现吗? 我知道的有java、scala python应该也可以吧

我这里是使用的是,kafka自带的zookeeper。 以及关于kafka的日志文件啊,都放在默认里即/tmp下,我没修改。保存默认的 1、[hadoop@sparksinglenode kafka_2.10-0.8.1.1]$ jps 2625 Jps 2、[hadoop@sparksinglenode kafka_2.10-0.8.1.1]$ bin/zoo...

接口回调,是Java多态的一种体现, 可以把使用某一接口的实现类创建的对象的引用, 赋给该接口声明的接口变量中, 那么该接口变量就可以调用被实现的接口中的方法, 当接口变量调用被类实现的接口中的方法时,就是通知相应的对象调用接口的方法。 观...

用一个跟用户表关联的表记录用户选择的模块,系统启动的时候,去读这个表的记录。 第一次由于这个表里没记录,自然就不会有任何模块了。再用一个表记录上次访问的地址,也是跟用户关联的。 启动的时候查询一下就可以了但缩略图可不好做了5915需...

纯java开发的软件在linux下面也可以应用自如。那么首先就需要配置好linux下的java环境,具体说来,就是配置jdk环境变量。 介绍在linux下配置jdk环境变量的几种常用方法。 首先在linux下安装jdk,如果出现提示权限不够(且root下也提示权限不够),...

:数据直接从通信网关过来?那最近每个map得到的数据是怎么区分的是发数据端按规则把数据配发到每个map?咱整过的一个例子是多个map同时从一张数据表取数进行数据处理在hdfs的输入目录给每个map指定一个输入文件map读取这个输入文件

首先你在链接时候检查是否代码里的IP 和端口是不是对的,端口是broker 端口,默认9092 ; 其次查看代码是生产者,看Kafka 集群里这个主题是否存在(如果不存在,默认是配置可以自动创建,看是非将该配置修改);然后检测防火墙,相应端口是否开...

JDK就是Java Development Kit.简单的说JDK是面向开发人员使用的SDK,它提供了Java的开发环境和运行环境。 SDK是Software Development Kit 一般指软件开发包,可以包括函数库、编译程序等。

一般消息发不出去很大可能都是配置或环境的问题 1、排查环境是否有问题,zookeeper节点是否存活,kafka节点是否存活,通过命令行的方式能否发出去消息(使用kafka-console-producer.sh),如果通过命令行都发不出去那就是集群的问题了。 2、网络...

/** * Kafka服务器连接参数 * Created by gerry on 12/21. */ public class KafkaBrokerInfo { // 主机名 public final String brokerHost; // 端口号 public final int brokerPort; /** * 构造方法 * * @param brokerHost Kafka服务器主机或者I...

网站地图

All rights reserved Powered by www.1862.net

copyright ©right 2010-2021。
www.1862.net内容来自网络,如有侵犯请联系客服。zhit325@qq.com