被kafka-client和springkafka版本坑到自闭及解决

<? xml version = "1.0" encoding = "UTF-8" ?>

< project xmlns = "http://maven.apache.org/POM/4.0.0" xmlns:xsi = "http://www.w3.org/2001/XMLSchema-instance"

    xsi:schemaLocation = "http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd" >

    < modelVersion >4.0.0</ modelVersion >

    < parent >

      < groupId >org.springframework.boot</ groupId >

      < artifactId >spring-boot-starter-parent</ artifactId >

      < version >2.1.5.RELEASE</ version >

      < relativePath /> <!-- lookup parent from repository -->

    </ parent >

    < groupId >com.example</ groupId >

    < artifactId >kafkaproducer</ artifactId >

    < version >0.0.1-SNAPSHOT</ version >

    < name >kafkaproducer</ name >

    < description >Demo project for Spring Boot</ description >

    < properties >

      < java.version >1.8</ java.version >

    </ properties >

    < dependencies >

      < dependency >

          < groupId >org.springframework.boot</ groupId >

          < artifactId >spring-boot-starter-web</ artifactId >

      </ dependency >

      < dependency >

          < groupId >org.projectlombok</ groupId >

          < artifactId >lombok</ artifactId >

          < optional >true</ optional >

      </ dependency >

      < dependency >

          < groupId >org.springframework.boot</ groupId >

          < artifactId >spring-boot-starter-test</ artifactId >

          < scope >test</ scope >

      </ dependency >

      < dependency >

          < groupId >org.springframework.kafka</ groupId >

          < artifactId >spring-kafka</ artifactId >

      </ dependency >

    </ dependencies >

    < build >

      < plugins >

          < plugin >

            < groupId >org.springframework.boot</ groupId >

            < artifactId >spring-boot-maven-plugin</ artifactId >

          </ plugin >

      </ plugins >

    </ build >

</ project >

server.port= 8089

spring.kafka.bootstrap-servers=ip:port

spring.kafka.producer.retries= 0

spring.kafka.producer.batch-size= 16384

spring.kafka.producer.buffer-memory= 33554432

spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer

spring.kafka.producer.value-serializer=org.apache.kafka.common.serialization.StringSerializer

spring.kafka.producer.linger.ms= 1

package com.example.kafkaproducer;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.kafka.core.KafkaTemplate;

import org.springframework.stereotype.Component;

@Component

public class KafkaProducer {

    @Autowired

    KafkaTemplate kafkaTemplate;

    public void produce(){

        kafkaTemplate.send( "test" , "hello word" );

        System.out.println( "发送消息" );

    }

}

package com.example.kafkaproducer;  

import org.junit.Test;

import org.junit.runner.RunWith;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.boot.test.context.SpringBootTest;

import org.springframework.test.context.junit4.SpringRunner; 

@RunWith (SpringRunner. class )

@SpringBootTest

public class KafkaproducerApplicationTests { 

    @Autowired KafkaProducer kafkaProducer; 

    @Test

    public void contextLoads() {

      kafkaProducer.produce();

    } 

}

./bin/kafka-console-consumer.sh --bootstrap-server ip:9092  --topic test

listeners = PLAINTEXT://your.host.name:9092

advertised.listeners=PLAINTEXT://your.host.name:9092