Skip to content

Commit d537b1f

Browse files
authored
Merge pull request #1522 from ozangunalp/kafka_4.0.0
Changes to kafka-streams-quickstart for Kafka 4.0.0
2 parents 1bd3f6c + e137fec commit d537b1f

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

kafka-streams-quickstart/aggregator/src/main/java/org/acme/kafka/streams/aggregator/streams/InteractiveQueries.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,7 @@ public class InteractiveQueries {
2828
KafkaStreams streams;
2929

3030
public List<PipelineMetadata> getMetaData() {
31-
return streams.allMetadataForStore(TopologyProducer.WEATHER_STATIONS_STORE)
31+
return streams.streamsMetadataForStore(TopologyProducer.WEATHER_STATIONS_STORE)
3232
.stream()
3333
.map(m -> new PipelineMetadata(
3434
m.hostInfo().host() + ":" + m.hostInfo().port(),

0 commit comments

Comments
 (0)