Skip to main content
Ctrl+K

Safir

  • User guide
  • API reference
  • Change log
  • Development guide
  • GitHub
  • User guide
  • API reference
  • Change log
  • Development guide
  • GitHub

Section Navigation

  • build_arq_redis_settings
  • ArqJobError
  • ArqMode
  • ArqQueue
  • JobMetadata
  • JobNotFound
  • JobNotQueued
  • JobResult
  • JobResultUnavailable
  • MockArqQueue
  • RedisArqQueue
  • WorkerSettings
  • build_worker
  • WorkerConfig
  • WorkerError
  • WorkerErrorType
  • WorkerFatalError
  • WorkerJobInfo
  • WorkerResult
  • WorkerTimeoutError
  • WorkerTransientError
  • WorkerUsageError
  • UWS_QUEUE_NAME
  • run_with_asyncio
  • AsyncMultiQueue
  • AsyncMultiQueueError
  • display_help
  • create_async_session
  • create_database_engine
  • datetime_from_db
  • datetime_to_db
  • drop_database
  • initialize_database
  • is_database_current
  • retry_async_transaction
  • run_migrations_offline
  • run_migrations_online
  • stamp_database
  • stamp_database_async
  • unstamp_database
  • AlembicConfigError
  • CountedPaginatedList
  • CountedPaginatedQueryRunner
  • DatabaseInitializationError
  • DatetimeIdCursor
  • InvalidCursorError
  • PaginatedList
  • PaginatedQueryRunner
  • PaginationCursor
  • format_datetime_for_logging
  • isodatetime
  • parse_isodatetime
  • parse_timedelta
  • ArqDependency
  • arq_dependency
  • DatabaseSessionDependency
  • db_session_dependency
  • auth_delegated_token_dependency
  • auth_dependency
  • auth_logger_dependency
  • HTTPClientDependency
  • DEFAULT_HTTP_TIMEOUT
  • http_client_dependency
  • LoggerDependency
  • logger_dependency
  • EventDependency
  • EventMaker
  • client_request_error_handler
  • ClientRequestError
  • SignedURLService
  • GitHubAppClientFactory
  • GitHubBlobModel
  • GitHubBranchCommitModel
  • GitHubBranchModel
  • GitHubCheckRunAnnotationLevel
  • GitHubCheckRunConclusion
  • GitHubCheckRunModel
  • GitHubCheckRunOutput
  • GitHubCheckRunPrInfoModel
  • GitHubCheckRunStatus
  • GitHubCheckSuiteConclusion
  • GitHubCheckSuiteId
  • GitHubCheckSuiteModel
  • GitHubCheckSuiteStatus
  • GitHubPullRequestHeadModel
  • GitHubPullRequestModel
  • GitHubPullState
  • GitHubRepoOwnerModel
  • GitHubRepositoryModel
  • GitHubUserModel
  • GitHubAppInstallationEventAction
  • GitHubAppInstallationEventModel
  • GitHubAppInstallationEventRepoModel
  • GitHubAppInstallationModel
  • GitHubAppInstallationRepositoriesEventAction
  • GitHubAppInstallationRepositoriesEventModel
  • GitHubCheckRunEventAction
  • GitHubCheckRunEventModel
  • GitHubCheckSuiteEventAction
  • GitHubCheckSuiteEventModel
  • GitHubPullRequestEventAction
  • GitHubPullRequestEventModel
  • GitHubPushEventModel
  • PaginationLinkData
  • AIOKafkaParams
  • Compatibility
  • FastStreamBrokerParams
  • FastStreamErrorHandler
  • IncompatibleSchemaError
  • InvalidAvroNameError
  • InvalidMetadataError
  • KafkaConnectionSettings
  • PlaintextSettings
  • PydanticSchemaManager
  • SaslMechanism
  • SaslPlaintextSettings
  • SaslSslSettings
  • SchemaInfo
  • SchemaManagerSettings
  • SchemaRegistryClientParams
  • SecurityProtocol
  • SslSettings
  • UnknownDeserializeError
  • UnknownSchemaError
  • initialize_kubernetes
  • add_log_severity
  • configure_alembic_logging
  • configure_logging
  • configure_uvicorn_logging
  • LogLevel
  • Profile
  • get_metadata
  • get_project_url
  • Metadata
  • metrics_configuration_factory
  • BaseAssertionError
  • BaseMetricsConfiguration
  • DisabledMetricsConfiguration
  • DuplicateEventError
  • EventManager
  • EventManagerUninitializedError
  • EventManagerUsageError
  • EventMetadata
  • EventPayload
  • EventPublisher
  • EventsConfiguration
  • FailedEventPublisher
  • KafkaEventManager
  • KafkaEventPublisher
  • KafkaMetricsConfiguration
  • KafkaTopicError
  • MockEventManager
  • MockEventPublisher
  • MockMetricsConfiguration
  • NoopEventManager
  • NoopEventPublisher
  • NotPublishedConsecutivelyError
  • NotPublishedError
  • PublishedCountError
  • PublishedList
  • PublishedTooFewError
  • UnsupportedAvroSchemaError
  • ANY
  • NOT_NONE
  • MetricsConfiguration
  • initialize_arq_metrics
  • make_on_job_start
  • publish_queue_stats
  • ArqEvents
  • ArqMetricsError
  • ArqQueueJobEvent
  • ArqQueueStatsEvent
  • ARQ_EVENTS_CONTEXT_KEY
  • ErrorDetail
  • ErrorLocation
  • ErrorModel
  • CaseInsensitiveFormMiddleware
  • CaseInsensitiveQueryMiddleware
  • XForwardedMiddleware
  • normalize_datetime
  • normalize_isodatetime
  • to_camel_case
  • validate_exactly_one_of
  • CamelCaseModel
  • EnvAsyncPostgresDsn
  • EnvRedisDsn
  • HumanTimedelta
  • IvoaIsoDatetime
  • SecondsTimedelta
  • UtcDatetime
  • DeserializeError
  • EncryptedPydanticRedisStorage
  • PydanticRedisStorage
  • before_send_handler
  • duration
  • fingerprint_env_handler
  • initialize_sentry
  • report_exception
  • sentry_exception_handler
  • should_enable_sentry
  • SentryConfig
  • SentryEventInfo
  • SlackBaseBlock
  • SlackBaseField
  • SlackCodeBlock
  • SlackCodeField
  • SlackException
  • SlackMessage
  • SlackTextBlock
  • SlackTextField
  • SlackWebException
  • SlackIgnoredException
  • SlackRouteErrorHandler
  • SlackWebhookClient
  • FullKafkaContainer
  • SchemaRegistryContainer
  • Data
  • patch_google_storage
  • MockBlob
  • MockBucket
  • MockStorageClient
  • patch_kubernetes
  • strip_none
  • MockKubernetesApi
  • parse_log_tuples
  • capture_events_fixture
  • sentry_init_fixture
  • Attachment
  • Captured
  • TestTransport
  • mock_slack_webhook
  • MockSlackWebhook
  • spawn_uvicorn
  • ServerNotListeningError
  • UvicornProcess
  • assert_job_summary_equal
  • patch_wobbly
  • MockUWSJobRunner
  • MockWobbly
  • Job
  • JobBase
  • JobCreate
  • JobError
  • JobResult
  • JobUpdateAborted
  • JobUpdateCompleted
  • JobUpdateError
  • JobUpdateExecuting
  • JobUpdateMetadata
  • JobUpdateQueued
  • ParameterError
  • ParametersModel
  • SerializedJob
  • UWSAppSettings
  • UWSApplication
  • UWSConfig
  • UWSError
  • UWSRoute
  • UsageError
  • API reference
  • PlaintextSettings

PlaintextSettings#

pydantic model safir.kafka.PlaintextSettings#

Subset of settings required for Plaintext auth.

Parameters:

data (Any)

Fields:
  • bootstrap_servers (str)

  • security_protocol (Literal[safir.kafka._kafka_config.SecurityProtocol.PLAINTEXT])

field bootstrap_servers: str [Required]#
field security_protocol: Literal[SecurityProtocol.PLAINTEXT] [Required]#
to_aiokafka_params()#
Return type:

AIOKafkaParams

to_faststream_params()#
Return type:

FastStreamBrokerParams

This page was last modified on 2026-07-28.

https://safir.lsst.io/api/safir.kafka.PlaintextSettings.html

previous

KafkaConnectionSettings

next

PydanticSchemaManager

This page was last modified on 2026-07-28.

On this page
  • PlaintextSettings
    • PlaintextSettings.bootstrap_servers
    • PlaintextSettings.security_protocol
    • PlaintextSettings.to_aiokafka_params()
    • PlaintextSettings.to_faststream_params()

Rubin Observatory

  • For scientists
  • News

Documentation

data.lsst.cloud

Community forum

© Copyright 2020-2024 Association of Universities for Research in Astronomy, Inc. (AURA).

The U.S. National Science Foundation (NSF) and the U.S. Department of Energy (DOE) Office of Science will support Rubin Observatory in its operations phase to carry out the Legacy Survey of Space and Time. They will also provide support for scientific research with the data. During operations, NSF funding is managed by the Association of Universities for Research in Astronomy (AURA) under a cooperative agreement with NSF, and DOE funding is managed by SLAC National Accelerator Laboratory (SLAC), under contract by DOE. Rubin Observatory is operated by NSF NOIRLab and SLAC.

NSF is an independent federal agency created by Congress in 1950 to promote the progress of science. NSF supports basic research and people to create knowledge that transforms the future.

The DOE Office of Science is the single largest supporter of basic research in the physical sciences in the United States and is working to address some of the most pressing challenges of our time.

Logos of the Vera C. Rubin Observatory, NSF, US DOE, NOIRLab, AURA, and SLAC.