私はIDEとしてEclipseを使用しています。私は非常に基本的な設定XMLファイルを持っているので、検証されず、Eclipseは何も実行しません。私は何が欠けていますか?Spring Integration Kafka設定 - Eclipseでのエラー
ここに私の設定のxmlだ:
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:int="http://www.springframework.org/schema/integration"
xmlns:int-kafka="http://www.springframework.org/schema/integration/kafka"
xmlns:task="http://www.springframework.org/schema/task"
xsi:schemaLocation="http://www.springframework.org/schema/integration/kafka http://www.springframework.org/schema/integration/kafka/spring-integration-kafka.xsd
http://www.springframework.org/schema/integration http://www.springframework.org/schema/integration/spring-integration.xsd
http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task.xsd">
<int:channel id="inputToKafka" />
<int-kafka:outbound-channel-adapter
id="kafkaOutboundChannelAdapter" kafka-template="template"
auto-startup="false" channel="inputToKafka" topic="replicated-topic-1"
message-key-expression="'bar'" partition-id-expression="2">
</int-kafka:outbound-channel-adapter>
<bean id="template" class="org.springframework.kafka.core.KafkaTemplate">
<constructor-arg>
<bean class="org.springframework.kafka.core.DefaultKafkaProducerFactory">
<constructor-arg>
<map>
<entry key="bootstrap.servers" value="192.168.33.21:9092,192.168.33.22:9092,192.168.33.23:9092" />
</map>
</constructor-arg>
</bean>
</constructor-arg>
</bean>
<int-kafka:message-driven-channel-adapter
id="kafkaListener"
listener-container="listenerContainer"
auto-startup="false"
phase="100"
send-timeout="5000"
channel="nullChannel"
error-channel="errorChannel" />
<bean id="listenerContainer" class="org.springframework.kafka.listener.KafkaMessageListenerContainer">
<constructor-arg>
<bean class="org.springframework.kafka.core.DefaultKafkaConsumerFactory">
<constructor-arg>
<map>
<entry key="bootstrap.servers" value="192.168.33.21:9092,192.168.33.22:9092,192.168.33.23:9092" />
</map>
</constructor-arg>
</bean>
</constructor-arg>
<constructor-arg name="topics" value="replicated-topic-1" />
</bean>
</beans>
ありがとうございました応答ゲイリー。実行時の問題ではないようです。正しいバージョンで解決するかどうかを確認し、見つけたものを更新します。 – code4kix
これでSTSを試しましたが、すべてのエラーが消えました。ランタイムエラーもありません。しかし、私がEclipseの計画を立てようと試みても、エラーを取り除くことはできません。あるものが別のものにつながり、あまりにも多くの葛藤があります。もう1つの理由は、Spring IntegrationのJava DSLを考慮する必要があります。 – code4kix
環境設定でXMLカタログ経由でそれを再現できるはずです。しかし、あなたを助けるSpringプラグインがあるとき、なぜ苦労しますか?明らかに、DSLはフローを構成するためのより現代的な方法ですが、XMLのような人々やこのスキーマは、一度整列させるとそれほど難しくありません。 –