不能使用netty和websocket

如果不能使用Netty和WebSocket，您可以使用Spring的Websocket支持来实现长连接。具体实现步骤如下：

1. 在Spring Boot项目中创建一个Controller类，用于处理客户端发送过来的请求。

2. 使用Server-Sent Events (SSE)协议来建立长连接，并将数据推送到客户端。

3. 在服务器端，您可以使用Kafka Producer将接收到的数据推送到Kafka集群中。

4. 最后，您需要在Kafka Consumer中订阅该主题，以便能够接收到从服务器端推送过来的数据。

以下是一个示例代码：

Controller类：

@Controller
public class MyController {

    @Autowired
    private KafkaTemplate<String, String> kafkaTemplate;

    @GetMapping(value = "/stream", produces = MediaType.TEXT_EVENT_STREAM_VALUE)
    public Flux<String> stream() {
        return Flux.create(sink -> {
            kafkaTemplate.send("my-topic", "test");
            Disposable disposable = KafkaConsumer.create(sink, "my-topic");
            sink.onCancel(disposable);
        });
    }
}

Kafka Producer：

@Component
public class KafkaProducer {

    @Autowired
    private KafkaTemplate<String, String> kafkaTemplate;

    public void send(String payload) {
        // 将数据发送到Kafka集群中
        kafkaTemplate.send("my-topic", payload);
    }
}

Kafka Consumer：

public class KafkaConsumer {

    public static Disposable create(FluxSink<String> sink, String topic) {
        KafkaConsumer<String, String> kafkaConsumer = new KafkaConsumer<>(createConfig());
        kafkaConsumer.subscribe(Collections.singleton(topic));

        return Flux.interval(Duration.ofMillis(100))
                .map(i -> kafkaConsumer.poll(Duration.ZERO))
                .filter(r -> !r.isEmpty())
                .map(ConsumerRecord::value)
                .doOnNext(sink::next)
                .doOnError(sink::error)
                .subscribe();
    }

    private static Map<String, Object> createConfig() {
        Map<String, Object> props = new HashMap<>();
        props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");
        props.put(ConsumerConfig.GROUP_ID_CONFIG, "my-group");
        props.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest");
        props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
        props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
        return props;
    }
}

在上面的代码中，我们创建了一个Controller类，用于接收客户端发送的请求。在该类中，我们使用了Spring的Webflux框架，并使用了SSE协议来建立长连接。当客户端连接到服务器时，我们将数据发送到Kafka集群中，并使用KafkaConsumer来订阅该主题，以便能够接收到从服务器端推送过来的数据。

希望这些步骤能够帮助您实现长连接发送数据到服务器端，再由服务器端通过Kafka推送出去的功能。