linux配置jdk、maven、kafka

linux

1、安装vmware
2、安装网络
cd /etc/sysconfig/network-scripts/
vi ifcfg-ens33 文件 将onboot 的值改为yes
修改的话需要键入 i 修改后 按esc 然后:wq！ 代表保存与退出
如果不想保存的话按esc后q，w代表保存
cat ifcfg-ens33查看
重启使其生效
service network restart
3、输入命令
yum install net-tools 添加ifconfig 命令支持
4、 添加vim 命令
yum -y install vim
5、 添加rz命令支持上传文件
yum install lrzsz

配置jdk环境（openjdk）

1 下载 yum -y install java-1.8.0-openjdk
2 配置环境变量 vim /etc/profile
3 export JAVA_HOME=/usr/lib/jvm/java-1.8.0-openjdk-1.8.0.232.b09-0.el7_7.x86_64
export PATH=$PATH:$PATH:JAVA_HOME/bin
4、或者添加外置的jdk"jdk-8u231-linux-x64.tar.gz"
5、source /etc/profile
java -version 命令检查是否安装成功

配置maven

1 使用rz命令上传maven
2 解压maven
tar vxf apache-maven-xx.bin.tar.gz
3移动命令
mv apache-maven-xxx /usr/local/maven3
vim /etc/profile
export MAVEN_HOME="/usr/local/maven3/apache-maven-xxx"
export PATH=${PATH}:$PATH:{MAVEN_HOME}/bin
最后输入使其生效
source /etc/profile
最后键入mvn -v 来看是否配置成功

配置kafka

1.使用rz命令上传kafka
2.使用解压命令解压kafka
3.修改kafka中配置文件 service.properties文件中
listeners = 改为自己的ip地址
4.关闭防火墙 systemctl stop firewalld
5.启动kafka以及zookeeper

bin/zookeeper-server-start.sh -daemon config/zookeeper.properties 
bin/kafka-server-start.sh -daemon config/server.properties
停止命令
bin/zkServer.sh stop
bin/kafka-server-stop.sh
使用jps查看当前进程可以查看当前是否启动成功

zookeeper在kafka中的作用是什么？

1.Borker注册
2.Topic注册
3.生产者负载均衡
4.消费者负载均衡
5.分区与消费的关系
6.消费者注册
名词解释
 Broker:
一台kafka服务器就是一个broke
 Topic：主题

在springboot项目中集成kafka

1.添加依赖

注意：这里的jar的版本和kafka的版本需要一致（1.1.1版本）

<dependency>
   <groupId>org.springframework.kafka</groupId>
   <artifactId>spring-kafka</artifactId>
   <version>1.1.1.RELEASE</version>
</dependency>

2添加配置

kafka:
  bootstrap-servers: 172.16.77.128:9092
  consumer:
    group-id: myGroup
    #反序列化
    key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
    value-deserializer: org.apache.kafka.common.serialization.StringDeserializer
  producer:
  #序列化
    key-serializer: org.apache.kafka.common.serialization.StringSerializer
    value-serializer: org.apache.kafka.common.serialization.StringSerializer

@Autowired
    private KafkaTemplate kafkaTemplate;

		@GetMapping(value = "/sendKafka")
    public void sendKafka(@RequestParam("msg") String msg) {
        kafkaTemplate.send("zwp", msg);
    }

    @KafkaListener(topics = "zwp")
    public void getKafkaMsg(ConsumerRecord<?,?> record){
        System.out.println(record);
    }