diff --git a/conf/indexer_journal_client.yml b/conf/indexer_journal_client.yml index de809b9..91877c9 100644 --- a/conf/indexer_journal_client.yml +++ b/conf/indexer_journal_client.yml @@ -1,9 +1,11 @@ -brokers: - - kafka +journal: + brokers: + - kafka + group_id: swh.indexer.journal_client + max_messages: 50 -consumer_id: swh.indexer.journal_client scheduler: cls: remote args: url: http://swh-scheduler-api:5008/ diff --git a/services/swh-indexer-journal-client/entrypoint.sh b/services/swh-indexer-journal-client/entrypoint.sh index 17cf7bf..22d19d0 100755 --- a/services/swh-indexer-journal-client/entrypoint.sh +++ b/services/swh-indexer-journal-client/entrypoint.sh @@ -1,25 +1,25 @@ #!/bin/bash set -e if [[ -d /src ]] ; then for srcrepo in /src/swh-* ; do pushd $srcrepo pip install -e . popd done fi echo Installed Python packages: pip list case "$1" in "shell") exec bash -i ;; *) echo "Starting swh-indexer-journal client" - exec wait-for-it kafka:9092 -s --timeout=0 -- python3 -m swh.indexer.journal_client + exec wait-for-it kafka:9092 -s --timeout=0 -- swh indexer --config-file /etc/softwareheritage/indexer/journal_client.yml journal-client ;; esac