카프카 정리 - kuyeol/Document GitHub Wiki

Kafka Streams

생성

<dependency>
    <groupId>io.quarkus</groupId>
    <artifactId>quarkus-messaging-kafka</artifactId>
</dependency>
@RegisterForReflection 
public class WeatherStation {

    public int id;
    public String name;
}

스트림 쿼리

@Produces

Topology

⚠️ **GitHub.com Fallback** ⚠️