Skip to content

Commit

Permalink
bug fixed: the max server id of kafka server should be Int32 rather t…
Browse files Browse the repository at this point in the history
…han Word32
  • Loading branch information
Commelina committed Mar 25, 2024
1 parent 1e78d2f commit c5c3178
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 1 deletion.
2 changes: 2 additions & 0 deletions docker/control-kafka/Dockerfile
Original file line number Diff line number Diff line change
Expand Up @@ -60,6 +60,8 @@ CMD /init-ssh.sh && \
--sub-via subscribe \
--time-limit 120 \
--final-time-limit 120 \
# This value is enough. A larger one can make elle exhausted.
--concurrency 5 \
## We do not support txns and idempotent for now.
## So we disable it.
--no-txn \
Expand Down
2 changes: 1 addition & 1 deletion docker/node-kafka/start-server.sh
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@
# Waiting for logdevice to start
sleep 2

SERVER_ID=$(shuf -i 1-4294967296 -n 1)
SERVER_ID=$(shuf -i 1-2147483647 -n 1) # Int32
MY_IP=$(hostname -I | head -n1 | awk '{print $1;}')
hstream-server kafka \
--config-path /etc/hstream/config.yaml \
Expand Down

0 comments on commit c5c3178

Please sign in to comment.