如何让Spring-remoting在Kafka上工作？

<bean id="kafkaTemplate" class="org.springframework.kafka.core.KafkaTemplate">
    <constructor-arg>
        <bean class="org.springframework.kafka.core.DefaultKafkaProducerFactory">
            <constructor-arg>
                <map>
                    <entry key="bootstrap.servers" value="kafka-server1:9092,kafka-server2:9092" />
                    <!-- 其他Kafka配置项 -->
                </map>
            </constructor-arg>
        </bean>
    </constructor-arg>
</bean>

<bean id="messageListenerContainer" class="org.springframework.kafka.listener.KafkaMessageListenerContainer">
    <constructor-arg>
        <bean class="org.springframework.kafka.core.DefaultKafkaConsumerFactory">
            <constructor-arg>
                <map>
                    <entry key="bootstrap.servers" value="kafka-server1:9092,kafka-server2:9092" />
                    <!-- 其他Kafka配置项 -->
                </map>
            </constructor-arg>
        </bean>
    </constructor-arg>
    <constructor-arg>
        <bean class="org.springframework.kafka.listener.ConcurrentMessageListenerContainer">
            <constructor-arg ref="kafkaTemplate" />
            <constructor-arg ref="messageListener" />
        </bean>
    </constructor-arg>
</bean>

<bean id="remoteService" class="org.springframework.remoting.httpinvoker.HttpInvokerProxyFactoryBean">
    <property name="serviceUrl" value="http://kafka-server1:8080/my-remote-service" />
    <property name="serviceInterface" value="com.example.MyRemoteService" />
</bean>

public interface MyRemoteService {
    void sendMessage(String message);
    // 其他方法
}

public class MyRemoteServiceImpl implements MyRemoteService {
    private KafkaTemplate<String, String> kafkaTemplate;
    
    // 注入KafkaTemplate
    public void setKafkaTemplate(KafkaTemplate<String, String> kafkaTemplate) {
        this.kafkaTemplate = kafkaTemplate;
    }
    
    public void sendMessage(String message) {
        kafkaTemplate.send("my-topic", message);
    }
    
    // 其他方法的实现
}

<bean id="myRemoteService" class="com.example.MyRemoteServiceImpl">
    <property name="kafkaTemplate" ref="kafkaTemplate" />
</bean>