diff --git a/docker/kafka-clusters-only.yaml b/docker/kafka-clusters-only.yaml index 8af7e1aac6..f4d19abb09 100644 --- a/docker/kafka-clusters-only.yaml +++ b/docker/kafka-clusters-only.yaml @@ -96,4 +96,5 @@ services: cub kafka-ready -b kafka1:29092 1 30 && \ kafka-topics --create --topic second.users --partitions 3 --replication-factor 1 --if-not-exists --zookeeper zookeeper1:2181 && \ kafka-topics --create --topic second.messages --partitions 2 --replication-factor 1 --if-not-exists --zookeeper zookeeper1:2181 && \ - kafka-console-producer --broker-list kafka1:29092 -topic second.users < /data/message.json'" + kafka-console-producer --broker-list kafka1:29092 -topic second.users < /data/message.json & \ + kafka-console-consumer --bootstrap-server kafka1:29092 --topic second.messages --from-beginning'" diff --git a/kafka-ui-react-app/src/redux/reducers/consumerGroups/reducer.ts b/kafka-ui-react-app/src/redux/reducers/consumerGroups/reducer.ts index 7973d600b7..6776dbcc58 100644 --- a/kafka-ui-react-app/src/redux/reducers/consumerGroups/reducer.ts +++ b/kafka-ui-react-app/src/redux/reducers/consumerGroups/reducer.ts @@ -19,7 +19,7 @@ const updateConsumerGroupsList = ( return payload.reduce( (memo: ConsumerGroupsState, consumerGroup) => ({ ...memo, - byId: { + byID: { ...memo.byID, [consumerGroup.consumerGroupId]: { ...memo.byID[consumerGroup.consumerGroupId],