pom.xml
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-stream-binder-kafka</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-stream-kafka</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-stream</artifactId>
</dependency>
版本号:/Users/zhangwei/.m2/repository/org/springframework/cloud/spring-cloud-starter-stream-kafka/3.1.1/spring-cloud-starter-stream-kafka-3.1.1.pom
xxx.java
import org.springframework.messaging.annotation.Input;
public interface KafkaStream {
String INPUT = "click-events-in";
String OUTPUT = "click-events-out";
@Input
SubscribableChannel clickEventsIn();
@Output
MessageChannel clickEventsOut();
}
上面引入的jar包Input报:Cannot resolve symbol 'annotation'
版本可能冲突了,只保留这个试试