获取json数据：private void sendRequestWithHttpClient() {new Thread(new Runnable() {@Overridepublic void run() {try {HttpClient httpClient = new DefaultHttpClient();// 指定访问的服务器地址是电脑本机Htt...

这一步问题比较多，容易超时可以失败后先参考该链接操作： https://www.cnblogs.com/ltlinux/p/11803557.html。在master上，将master中的admin.conf 拷贝到node中,这里是scp的方式，使用客户端手动上传也是可以的。因此最后决定根据官方的文档来部署，还能更熟悉一下基本的角色组成。sysctl -p /etc/sysctl.d/k8s.c

需求： 获取kafka 最新的offset方法： 获取kafka每个分区的offsetmethod1 使用consumer.seektoend()method2 使用consumer.endOffsets()版本<dependency><groupId>org.apache.kafka</groupId>...

需求在使用flume 收集 log的时候根据 不同的 消息表示可能是uid。或者是日期。等关键字段 。将消息发送到 kafka不同的分区这里就不再贴详细代码 主要讲一下自己的思路 。思路一： 自定义在flume拦截器中 使用kafka producer 。直接将关键信息 获取之后。根据逻辑。发送到不同的分区 。主要实现如图：配置文件修改：flume-co...