为什么我的Kafka制作人不能发布消息？

Question

我无法向Kafka主题发布消息，无法得到Kafka制作人的任何回应，它完全卡住了应用程序

Kafka生产者服务代码

@Service(value = "bookServiceImpl")
public class BookServiceImpl implements IBookService{
    @Autowired
    private KafkaTemplate<String,Book> kafkaTemplate;

    @Override
    public String sendBooksDetails(List<Book> booksList) {
        String msg = "";
        int index = 0;
        try {
            if (!booksList.isEmpty()){
                for (Book book:booksList) {
                    kafkaTemplate.send(KafkaConstants.TOPIC,book);
                }
            }
            msg = "Books are added to kafka topic successfully";
        }catch (Exception e){
            e.printStackTrace();
            msg = "Unable to publish message";
        }
        return msg;
    }
}

@Configuration
public class KafkaProducerConfig {

    @Bean
    public ProducerFactory<String, Book> producerFactory(){
        Map<String,Object> configProps = new HashMap<>();
        configProps.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, KafkaConstants.HOST);
        configProps.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
        configProps.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, JsonSerializer.class);

        return new DefaultKafkaProducerFactory<>(configProps);
    }

    @Bean
    public KafkaTemplate<String,Book> kafkaTemplate(){
        return new KafkaTemplate<>(producerFactory());
    }
}

2021-05-30 13:29:13.209[0；39M[32M信息[0；39M[35M2472[0；39M[2M---[0；39M[2M[nio-8084-exec-2][0；39M[36MO.apache.coyote.http11.HTTP11Processor[0；39M[2M:[0；39M错误解析HTTP请求头注意：将在调试级别记录HTTP请求解析错误的进一步出现。

java.lang.IllegalArgumentException:在方法名[0x000x000x00.0x000x120x000x030x000x000x000x000x000x000x0aProducer-10x000x12Apache-kafka-java0x062.6.0...]中发现无效字符。HTTP方法名必须是在org.apache.coyote.http11.http11inputbuffer.parserequestline(http11inputbuffer.java:417)~[tomcat-embed-core-9.0.45.jar:9.0.45]在org.apache.coyote.http11.http11processor.service(http11processor.java:261)~[tomcat-embed-core-9.0.45.jar:9.0.45]在te.abstractProtocol$ConnectionHandler.process(abstractProtocol.java:893)~[tomcat-embed-core-9.0.45.jar:9.0.45]在org.apache.tomcat.util.net.nioendpoint$socketprocessor.dorun(Nioendpoint.java:1707)~[tomcat-embed-core-9.0.45.jar:9.0.45]在worker(threadpoolexecutor.java:1130)~[na:na]在java.base/java.util.concurrent.threadpoolexecutor$worker.run(threadpoolexecutor.java:630)~[na:na]在org.apache.ttaskthread$wrappingrunnable.run(taskthread.java:61)~[tomcat-embed-core-9.0.45.jar:9.0.45]at java.base/java.lang.thread.run(thread.java:832)~[na:na]

[2M2021-05-30 13:29:15.276[0；39M[33M Warn[0；39M[35M2472[0；39M[2M----[0；39M[2M[ad producer-1][0；39M[36Morg.apache.kafka.clients.NetworkClient[0；39M[2M:[0；39M[Producer Clientid=producer-1]引导代理本地主机:8084(ID:-1 RACK:null)断开连接[2M2021-05-30 13:29:15.531[0；39M[33M Warn[0；39M[35M2472[0；0；39M[2M[ad producer-1][0；39M[36morg.apache.kafka.clients.NetworkClient[0；39M[2M:[0；39M[Producer Clientid=producer-1]Bootstrap broker本地主机：8084（ID：-1 RACK：null）已断开连接

Answer 1

当您试图在未启用HTTPS的endpoint上执行来自客户端的HTTPS请求时，可能会发生此异常。当服务器需要原始数据时，客户端将对请求数据进行加密。