Public scan — anyone with this URL can view this analysis. Sign up to track your own repos privately, run scheduled re-scans, and get AI fix prompts via your dashboard.

confluentinc/quickstart-streaming-agents

https://github.com/confluentinc/quickstart-streaming-agents · scanned 2026-05-15 14:47 UTC (2 weeks, 6 days ago) · 10 languages

46 findings (18 legacy + 28 scanner) 51st percentile · Python · small (2-20K LoC) Scanner says 82 (lower by 11)

UNIFIED Repobility · multi-layer engine · AI coders

Complete repo analysis

Last scanned 2 weeks, 6 days ago · v1 · 13 findings from 1 source. Findings combine the legacy security pipeline AND the multi-layer engine (atlas, wiring, flows, ranked) AND verified AI agent contributions.

JSON
Score breakdown â 2026-05-14-v3
Component Sub-score Weight Contribution
structure_score 75.0 0.15 11.25
security_score 72.4 0.25 18.10
testing_score 95.0 0.20 19.00
documentation_score 74.0 0.15 11.10
practices_score 40.0 0.15 6.00
code_quality 56.2 0.10 5.62
Overall 1.00 71.1
Severity distribution — click a segment to filter
Active filters: excluding tests × Reset all

All 558 nodes from the latest scan, grouped by kind. Each node is a unit the engine identified (file, function, endpoint, table…). Most users won't need this view — it's primarily for debugging the engine's graph extraction or for AI agents that want to enumerate the project structure.

LabelLayerStatusPath
_save_env_safe software healthy deploy.py:69
_flush_pending_writes software healthy deploy.py:100
_print_write_error software healthy deploy.py:125
main software healthy deploy.py:138
pytest_runtest_logreport software healthy testing/conftest.py:29
pytest_sessionfinish software healthy testing/conftest.py:34
_write_failure_summary software healthy testing/conftest.py:61
_is_interactive software healthy testing/conftest.py:76
_claude_available software healthy testing/conftest.py:80
ensure_confluent_cli_installed software healthy testing/conftest.py:84
ensure_confluent_login software healthy testing/conftest.py:97
load_test_credentials software healthy testing/conftest.py:165
write_credentials_to_project_root software healthy testing/conftest.py:235
remove_credentials_from_project_root software healthy testing/conftest.py:246
project_root software healthy testing/conftest.py:254
testing_dir software healthy testing/conftest.py:260
_ok_result software healthy testing/unit/test_login_checks.py:22
test_returns_true_when_command_succeeds software healthy testing/unit/test_login_checks.py:28
test_returns_true_with_empty_environment_list software healthy testing/unit/test_login_checks.py:34
test_returns_false_on_called_process_error software healthy testing/unit/test_login_checks.py:42
test_returns_false_when_confluent_not_installed software healthy testing/unit/test_login_checks.py:49
test_calls_correct_command software healthy testing/unit/test_login_checks.py:56
_login_ok software healthy testing/unit/test_login_checks.py:380
_login_fail software healthy testing/unit/test_login_checks.py:387
test_returns_false_when_creds_empty software healthy testing/unit/test_login_checks.py:93
test_returns_false_when_email_missing software healthy testing/unit/test_login_checks.py:96
test_returns_false_when_password_missing software healthy testing/unit/test_login_checks.py:99
test_returns_false_when_email_empty_string software healthy testing/unit/test_login_checks.py:105
test_returns_false_when_password_empty_string software healthy testing/unit/test_login_checks.py:113
test_returns_false_when_only_tf_var_owner_email_provided software healthy testing/unit/test_login_checks.py:123
test_returns_false_on_bad_password software healthy testing/unit/test_login_checks.py:133
test_returns_false_on_bad_email software healthy testing/unit/test_login_checks.py:144
test_prints_stdout_when_stderr_empty software healthy testing/unit/test_login_checks.py:155
test_prints_nothing_extra_on_success software healthy testing/unit/test_login_checks.py:162
test_returns_true_when_login_and_check_both_pass software healthy testing/unit/test_login_checks.py:178
test_returns_false_when_login_ok_but_check_fails software healthy testing/unit/test_login_checks.py:190
test_passes_credentials_via_stdin software healthy testing/unit/test_login_checks.py:451
test_uses_save_flag software healthy testing/unit/test_login_checks.py:465
test_password_with_special_characters software healthy testing/unit/test_login_checks.py:479
test_returns_when_already_logged_in software healthy testing/unit/test_login_checks.py:258
test_auto_login_from_creds_on_not_logged_in software healthy testing/unit/test_login_checks.py:264
test_exits_when_not_logged_in_and_no_creds software healthy testing/unit/test_login_checks.py:277
test_exits_when_auto_login_fails software healthy testing/unit/test_login_checks.py:291
test_no_creds_arg_loads_from_env_file software healthy testing/unit/test_login_checks.py:305
test_error_message_contains_manual_login_hint software healthy testing/unit/test_login_checks.py:326
test_error_message_contains_redeploy_hint software healthy testing/unit/test_login_checks.py:341
test_error_message_contains_sso_hint software healthy testing/unit/test_login_checks.py:356
test_returns_true_on_successful_login software healthy testing/unit/test_login_checks.py:394
test_returns_false_on_subprocess_failure software healthy testing/unit/test_login_checks.py:406
test_returns_false_when_check_fails_after_login software healthy testing/unit/test_login_checks.py:413

Showing first 50 of this kind. Full payload available via the JSON button at the top of the page.

LabelLayerStatusPath
LAB3-Walkthrough.md software healthy LAB3-Walkthrough.md
deploy.py software healthy deploy.py
LAB4-Walkthrough.md software healthy LAB4-Walkthrough.md
LAB2-Walkthrough.md software healthy LAB2-Walkthrough.md
service.yml software healthy service.yml
README.md software healthy README.md
LAB1-Walkthrough.md software healthy LAB1-Walkthrough.md
pyproject.toml software healthy pyproject.toml
conftest.py software healthy testing/conftest.py
README.md software healthy testing/README.md
__init__.py software healthy testing/unit/__init__.py
test_login_checks.py software healthy testing/unit/test_login_checks.py
test_deploy_login.py software healthy testing/unit/test_deploy_login.py
test_downstream_login.py software healthy testing/unit/test_downstream_login.py
__init__.py software healthy testing/helpers/__init__.py
terraform_helper.py software healthy testing/helpers/terraform_helper.py
flink_sql_helper.py software healthy testing/helpers/flink_sql_helper.py
polling_helper.py software healthy testing/helpers/polling_helper.py
deployment_state_helper.py software healthy testing/helpers/deployment_state_helper.py
kafka_helper.py software healthy testing/helpers/kafka_helper.py
test_sql_extraction.py software healthy testing/e2e/test_sql_extraction.py
__init__.py software healthy testing/e2e/__init__.py
test_lab1.py software healthy testing/e2e/test_lab1.py
test_smoke.py software healthy testing/e2e/test_smoke.py
test_lab4.py software healthy testing/e2e/test_lab4.py
test_lab2.py software healthy testing/e2e/test_lab2.py
test_lab3.py software healthy testing/e2e/test_lab3.py
test_workshop_keys.py software healthy testing/e2e/test_workshop_keys.py
publish_lab1_data.py software healthy scripts/publish_lab1_data.py
publish_lab3_data.py software healthy scripts/publish_lab3_data.py
__init__.py software healthy scripts/__init__.py
lab3_datagen.py software healthy scripts/lab3_datagen.py
lab4_datagen.py software healthy scripts/lab4_datagen.py
lab1_datagen.py software healthy scripts/lab1_datagen.py
generate_lab1_data.py software healthy scripts/generate_lab1_data.py
publish_docs.py software healthy scripts/publish_docs.py
capture_lab1_data.py software healthy scripts/capture_lab1_data.py
run_tests.py software healthy scripts/run_tests.py
capture_lab3_data.py software healthy scripts/capture_lab3_data.py
lab2_publish_queries.py software healthy scripts/lab2_publish_queries.py
setup_rtce.py software healthy scripts/setup_rtce.py
mcp_setup.py software healthy scripts/mcp_setup.py
datagen_helpers.py software healthy scripts/common/datagen_helpers.py
validate.py software healthy scripts/common/validate.py
workshop_key_manager.py software healthy scripts/common/workshop_key_manager.py
test_mongodb_credentials.py software healthy scripts/common/test_mongodb_credentials.py
__init__.py software healthy scripts/common/__init__.py
clear_mongodb.py software healthy scripts/common/clear_mongodb.py
terraform_runner.py software healthy scripts/common/terraform_runner.py
terraform.py software healthy scripts/common/terraform.py

Showing first 50 of this kind. Full payload available via the JSON button at the top of the page.

LabelLayerStatusPath
tf::confluent_flink_statement::mongodb_connection_statement… hardware healthy terraform/lab3-agentic-fleet-management/main.tf
tf::confluent_flink_statement::documents_vectordb_lab3 hardware healthy terraform/lab3-agentic-fleet-management/main.tf
tf::confluent_flink_statement::remote_mcp_connection_lab3 hardware healthy terraform/lab3-agentic-fleet-management/main.tf
tf::confluent_flink_statement::remote_mcp_model_lab3_aws hardware healthy terraform/lab3-agentic-fleet-management/main.tf
tf::confluent_flink_statement::remote_mcp_model_lab3_azure hardware healthy terraform/lab3-agentic-fleet-management/main.tf
tf::confluent_flink_statement::ride_requests_table hardware healthy terraform/lab3-agentic-fleet-management/main.tf
tf::null_resource::generate_flink_sql_summary hardware healthy terraform/lab3-agentic-fleet-management/main.tf
tf::random_id::resource_suffix hardware healthy terraform/core/main.tf
tf::confluent_environment::staging hardware healthy terraform/core/main.tf
tf::confluent_kafka_cluster::standard hardware healthy terraform/core/main.tf
tf::confluent_flink_connection::bedrock_connection hardware healthy terraform/core/main.tf
tf::confluent_flink_connection::bedrock_embedding_connection hardware healthy terraform/core/main.tf
tf::confluent_flink_connection::azureopenai_connection hardware healthy terraform/core/main.tf
tf::confluent_flink_connection::azureopenai_embedding_conne… hardware healthy terraform/core/main.tf
tf::confluent_flink_statement::llm_textgen_model_aws hardware healthy terraform/core/main.tf
tf::confluent_flink_statement::llm_textgen_model_azure hardware healthy terraform/core/main.tf
tf::confluent_flink_statement::llm_embedding_model_aws hardware healthy terraform/core/main.tf
tf::confluent_flink_statement::llm_embedding_model_azure hardware healthy terraform/core/main.tf
tf::confluent_flink_statement::claims_table hardware healthy terraform/lab4-pubsec-fraud-agents/main.tf
tf::confluent_flink_statement::cosmosdb_connection_statemen… hardware healthy terraform/lab4-pubsec-fraud-agents/main.tf
tf::confluent_flink_statement::fema_policies_vectordb_azure hardware healthy terraform/lab4-pubsec-fraud-agents/main.tf
tf::confluent_flink_statement::mongodb_connection_statement… hardware healthy terraform/lab4-pubsec-fraud-agents/main.tf
tf::confluent_flink_statement::fema_policies_vectordb_aws hardware healthy terraform/lab4-pubsec-fraud-agents/main.tf
tf::null_resource::run_datagen hardware healthy terraform/lab4-pubsec-fraud-agents/main.tf
tf::random_id::lab_suffix hardware healthy terraform/lab2-vector-search/main.tf
tf::confluent_flink_statement::mongodb_connection_statement… hardware healthy terraform/lab2-vector-search/main.tf
tf::confluent_flink_statement::queries_table hardware healthy terraform/lab2-vector-search/main.tf
tf::confluent_flink_statement::queries_embed_table hardware healthy terraform/lab2-vector-search/main.tf
tf::confluent_flink_statement::queries_insert_sample hardware healthy terraform/lab2-vector-search/main.tf
tf::confluent_flink_statement::documents_vectordb_create_ta… hardware healthy terraform/lab2-vector-search/main.tf
tf::confluent_flink_statement::queries_embed_insert_into hardware healthy terraform/lab2-vector-search/main.tf
tf::confluent_flink_statement::search_results_create_table hardware healthy terraform/lab2-vector-search/main.tf
tf::confluent_flink_statement::search_results_response_crea… hardware healthy terraform/lab2-vector-search/main.tf
tf::null_resource::generate_flink_sql_summary hardware healthy terraform/lab2-vector-search/main.tf
tf::random_id::lab_suffix hardware healthy terraform/lab1-tool-calling/main.tf
tf::confluent_flink_statement::remote_mcp_connection hardware healthy terraform/lab1-tool-calling/main.tf
tf::confluent_flink_statement::remote_mcp_model_aws hardware healthy terraform/lab1-tool-calling/main.tf
tf::confluent_flink_statement::remote_mcp_model_azure hardware healthy terraform/lab1-tool-calling/main.tf
tf::null_resource::generate_flink_sql_summary hardware healthy terraform/lab1-tool-calling/main.tf
tf::confluent_flink_statement::orders_table hardware healthy terraform/lab1-tool-calling/main.tf
tf::confluent_flink_statement::products_table hardware healthy terraform/lab1-tool-calling/main.tf
tf::confluent_flink_statement::customers_table hardware healthy terraform/lab1-tool-calling/main.tf

LabelLayerStatusPath
TestCheckConfluentLogin software healthy testing/unit/test_login_checks.py:21
TestAttemptConfluentAutoLogin software healthy testing/unit/test_login_checks.py:74
TestEnsureConfluentLogin software healthy testing/unit/test_login_checks.py:255
TestAttemptLoginQuiet software healthy testing/unit/test_login_checks.py:377
_StopAfterLogin software healthy testing/unit/test_deploy_login.py:14
TestDeployInteractiveStep0 software healthy testing/unit/test_deploy_login.py:58
TestDeployAutomatedLogin software healthy testing/unit/test_deploy_login.py:245
TestDeployTestingLogin software healthy testing/unit/test_deploy_login.py:318
_StopAfterLogin software healthy testing/unit/test_downstream_login.py:18
TestDestroyLogin software healthy testing/unit/test_downstream_login.py:27
TestPublishDocsLogin software healthy testing/unit/test_downstream_login.py:108
TestLab2PublishLogin software healthy testing/unit/test_downstream_login.py:170
TerraformHelper software healthy testing/helpers/terraform_helper.py:18
FlinkSQLHelper software healthy testing/helpers/flink_sql_helper.py:10
KafkaHelper software healthy testing/helpers/kafka_helper.py:25
TestLab1PriceMatch software healthy testing/e2e/test_lab1.py:119
TestLab4FraudDetection software healthy testing/e2e/test_lab4.py:145
TestLab2VectorSearch software healthy testing/e2e/test_lab2.py:47
TestLab3FleetManagement software healthy testing/e2e/test_lab3.py:120
Lab1DataPublisher software healthy scripts/publish_lab1_data.py:144
Lab3DataPublisher software healthy scripts/publish_lab3_data.py:173
Lab4DataPublisher software healthy scripts/lab4_datagen.py:62
FlinkDocsPublisherCLI software healthy scripts/publish_docs.py:59
QueryPublisherCLI software healthy scripts/lab2_publish_queries.py:55
MaxKeysReached software healthy scripts/common/workshop_key_manager.py:122

LabelLayerStatusPath
testing software healthy testing
unit software healthy testing/unit
helpers software healthy testing/helpers
e2e software healthy testing/e2e
scripts software healthy scripts
common software healthy scripts/common
assets software healthy assets
pre-setup software healthy assets/pre-setup
lab1 software healthy assets/lab1
competitor-site software healthy assets/lab1/competitor-site
terraform software healthy terraform
lab3-agentic-fleet-management software healthy terraform/lab3-agentic-fleet-management
data-gen software healthy terraform/lab3-agentic-fleet-management/data-gen
functions software healthy terraform/lab3-agentic-fleet-management/data-gen/functions
zones software healthy terraform/lab3-agentic-fleet-management/data-gen/zones
generators software healthy terraform/lab3-agentic-fleet-management/data-gen/generators
core software healthy terraform/core
lab4-pubsec-fraud-agents software healthy terraform/lab4-pubsec-fraud-agents
lab2-vector-search software healthy terraform/lab2-vector-search
lab1-tool-calling software healthy terraform/lab1-tool-calling
data-gen software healthy terraform/lab1-tool-calling/data-gen
generators software healthy terraform/lab1-tool-calling/data-gen/generators
.github software healthy .github

LabelLayerStatusPath
password_literal::deploy.py security healthy deploy.py
password_literal::scripts/common/datagen_helpers.py security healthy scripts/common/datagen_helpers.py
password_literal::scripts/common/tfvars.py security healthy scripts/common/tfvars.py

LabelLayerStatusPath
vps::aws hardware healthy deploy.py
vps::azure hardware healthy deploy.py

LabelLayerStatusPath
repobility-clone-ibyz5l4t software healthy /tmp/repobility-clone-ibyz5l4t

LabelLayerStatusPath
mongodb data healthy deploy.py

LabelLayerStatusPath
kafka data healthy pyproject.toml
For AI agents: Voting guide (TP/FP) MCP manifest Stdio wrapper SARIF Integrate Findings queue Vote TP/FP on findings to calibrate the engine.
For AI agents + API integrations
Email me when this repo regresses
Free. We re-scan periodically; new criticals → your inbox. No signup required for the scan itself.
API access

This page is publicly accessible at: https://repobility.com/scan/1be990eb-99e8-42fb-9096-fc9bf6f5319f/

To check status programmatically (no auth required):

curl -s https://repobility.com/api/v1/public/scan/1be990eb-99e8-42fb-9096-fc9bf6f5319f/

Important — please don't re-submit the same URL repeatedly. The submission endpoint is idempotent: re-submitting the same git URL returns this same scan_token, not a new one. To re-scan this repo, sign up free and use the dashboard.