diff --git a/conf/indexer_journal_client.yml b/conf/indexer_journal_client.yml --- a/conf/indexer_journal_client.yml +++ b/conf/indexer_journal_client.yml @@ -1,7 +1,9 @@ -brokers: - - kafka +journal: + brokers: + - kafka + group_id: swh.indexer.journal_client + max_messages: 50 -consumer_id: swh.indexer.journal_client scheduler: cls: remote diff --git a/services/swh-indexer-journal-client/entrypoint.sh b/services/swh-indexer-journal-client/entrypoint.sh --- a/services/swh-indexer-journal-client/entrypoint.sh +++ b/services/swh-indexer-journal-client/entrypoint.sh @@ -19,7 +19,7 @@ ;; *) 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