use YDB_KAFKA_PROXY_PORT for enable kafka #12242
Conversation
|
⚪ Test history | Ya make output | Test bloat
🟢 |
rekby
force-pushed
the
11005-local-kafka-api
branch
from
4d7700e to
49eae52
Compare
rekby
force-pushed
the
11005-local-kafka-api
branch
from
49eae52 to
63f9488
Compare
|
⚪ Test history | Ya make output | Test bloat
⚪ Test history | Ya make output | Test bloat | Test bloat
🟢
*please be aware that the difference is based on comparing your commit and the last completed build from the post-commit, check comparation |
|
⚪ Test history | Ya make output | Test bloat
🟢
*please be aware that the difference is based on comparing your commit and the last completed build from the post-commit, check comparation |
| if _is_env_option_enabled('YDB_KAFKA_API_ENABLED'): | ||
| kafka_api_port = int(os.environ.get("YDB_KAFKA_PROXY_PORT", "9092")) | ||
| kafka_api_port = int(os.environ.get("YDB_KAFKA_PROXY_PORT", "0")) | ||
| if kafka_api_port != 0: |
There was a problem hiding this comment.
У тебя ошибка фактическая: по дефолту возвращается "0", а сравниваешь с 0
There was a problem hiding this comment.
Предлагаю
kafka_api_port = int(os.environ.get("YDB_KAFKA_PROXY_PORT"))
if kafka_api_port is not None:
...
There was a problem hiding this comment.
у меня там ещё приведение к int-у есть:
int(os.environ.get("YDB_KAFKA_PROXY_PORT", "0"))
2 participants
Changelog entry
...
Changelog category
Additional information
...