Skip to content

Commit e137fec

Browse files
committed
Bumped Kafka to 4.0.0
1 parent 9655c48 commit e137fec

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)