瀏覽代碼

Fixed consumer groups pages.

Sofia Shnaidman 4 年之前
父節點
當前提交
32a9af231f
共有 2 個文件被更改,包括 3 次插入2 次删除
  1. 2 1
      docker/kafka-clusters-only.yaml
  2. 1 1
      kafka-ui-react-app/src/redux/reducers/consumerGroups/reducer.ts

+ 2 - 1
docker/kafka-clusters-only.yaml

@@ -96,4 +96,5 @@ services:
                cub kafka-ready -b kafka1:29092 1 30 && \
                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.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-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'"

+ 1 - 1
kafka-ui-react-app/src/redux/reducers/consumerGroups/reducer.ts

@@ -19,7 +19,7 @@ const updateConsumerGroupsList = (
   return payload.reduce(
   return payload.reduce(
     (memo: ConsumerGroupsState, consumerGroup) => ({
     (memo: ConsumerGroupsState, consumerGroup) => ({
       ...memo,
       ...memo,
-      byId: {
+      byID: {
         ...memo.byID,
         ...memo.byID,
         [consumerGroup.consumerGroupId]: {
         [consumerGroup.consumerGroupId]: {
           ...memo.byID[consumerGroup.consumerGroupId],
           ...memo.byID[consumerGroup.consumerGroupId],