Skip to content

KumoMTA Docs

module: kumo.kafka

Initializing search

KumoCorp/kumomta

Tutorial
User Guide
Reference Manual
FAQ
Changelog

KumoMTA Docs

KumoCorp/kumomta

Tutorial
Tutorial
User Guide
User Guide
Reference Manual
Reference Manual
- Predefined Metadata
- Queues
- Log Record
- kcli
  kcli
- module: kumo
  module: kumo
- module: kumo.amqp
  module: kumo.amqp
  - build_client
- module: kumo.api.inject
  module: kumo.api.inject
  - inject_v1
- module: kumo.digest
  module: kumo.digest
  - sha1
  - sha256
  - sha384
  - sha512
  - sha512_256
- module: kumo.dkim
  module: kumo.dkim
  - ed25519_signer
  - rsa_sha256_signer
- module: kumo.dns
  module: kumo.dns
- module: kumo.encode
  module: kumo.encode
- module: kumo.cidr
  module: kumo.cidr
  - make_map
- module: kumo.domain_map
  module: kumo.domain_map
  - new
- module: kumo.http
  module: kumo.http
- module: kumo.kafka
  module: kumo.kafka
  - build_producer
- module: kumo.regex_set_map
  module: kumo.regex_set_map
  - new
- module: kumo.secrets
  module: kumo.secrets
  - load
- module: kumo.serde
  module: kumo.serde
- module: kumo.shaping
  module: kumo.shaping
  - load
- module: kumo.uuid
  module: kumo.uuid
  - new_v1
  - new_v4
  - new_v6
  - new_v7
  - parse
- module: redis
  module: redis
  - open
- module: regex
  module: regex
  - compile
  - escape
- module: sqlite
  module: sqlite
  - open
- module: string
  module: string
  - psl_domain
  - psl_suffix
  - replace
  - replacen
  - rsplit
  - rsplitn
  - split
  - split_ascii_whitespace
  - split_whitespace
  - splitn
  - trim
  - trim_end
  - trim_start
- module: tsa
  module: tsa
  - configure_tsa_db_path
  - start_http_listener
- object: address
  object: address
  - domain
  - email
  - user
- object: addressheader
  object: addressheader
  - domain
  - email
  - list
  - name
  - user
- object: authenticationresult
- object: connectionmeta
- object: keysource
- object: message
  object: message
- events
  events
- HTTP API Explorer
- HTTP API
  HTTP API
- Internal Rust API
  Internal Rust API
  - bounce_classify
  - cidr_map
  - config
  - data_loader
  - dns_resolver
  - domain_map
  - duration_serde
  - kumo_api_types
  - kumo_chrono_helper
  - kumo_dkim
  - kumo_log_types
  - kumo_server_common
  - kumo_server_lifecycle
  - kumo_server_memory
  - kumo_server_runtime
  - lruttl
  - maildir
  - mailparsing
  - message
  - mod_amqp
  - mod_digest
  - mod_dns_resolver
  - mod_encode
  - mod_filesystem
  - mod_http
  - mod_kafka
  - mod_memoize
  - mod_redis
  - mod_regex
  - mod_serde
  - mod_sqlite
  - mod_string
  - mod_uuid
  - mta_sts
  - regex_set_map
  - rfc5321
  - spool
  - throttle
  - timeq
  - uuid_helper
  - version_info
FAQ
FAQ
Changelog
Changelog

Table of contents

Available Functions

Module `kumo.amqp`

This module provides Apache Kafka client functionality.

Available Functions

build_producer

2024-07-26 2024-07-26

connect_websocket

Copyright © 2023 Kumo Corp

Made with Material for MkDocs