Docs.rs
  • ene_kafka-0.2.0
    • ene_kafka 0.2.0
    • Permalink
    • Docs.rs crate page
    • Apache-2.0
    • Links
    • Repository
    • crates.io
    • Source
    • Owners
    • Abdullahsab3
    • Dependencies
      • anyhow ^1.0.86 normal
      • async-trait ^0.1.82 normal
      • chrono ^0.4.38 normal
      • rdkafka ^0.36.2 normal
      • serde ^1.0.209 normal
      • serde_json ^1.0.128 normal
      • tokio ^1.40.0 normal
      • tracing ^0.1.40 normal
      • tracing-subscriber ^0.3.18 normal
      • uuid ^1.10.0 normal
    • Versions
    • 6.33% of the crate is documented
  • Platform
    • i686-unknown-linux-gnu
    • x86_64-unknown-linux-gnu
  • Feature flags
  • docs.rs
    • About docs.rs
    • Privacy policy
  • Rust
    • Rust website
    • The Book
    • Standard Library API Reference
    • Rust by Example
    • The Cargo Guide
    • Clippy Documentation

ene_kafka0.2.0

Crate Items

  • Macros
  • Structs
  • Enums
  • Traits
  • Functions
  • Type Aliases

List of all items

Structs

  • admins::KafkaAdmin
  • consumers::consumer::KafkaConsumer
  • messages::kafka_message::KafkaTopic
  • producers::producer::KafkaProducer

Enums

  • messages::kafka_message::ContentType

Traits

  • admins::KafkaAdminInterface
  • consumers::consumer::KafkaConsumerInterface
  • dispatchers::EventDispatcher
  • handlers::EventHandler
  • messages::cloud_events::cloud_event::CloudEvent
  • messages::cloud_events::cloud_event::DeserializeFrom
  • messages::kafka_message::KafkaMessage
  • messages::kafka_message::ToBytes
  • messages::rdkafka_impl::ToRdkafkaHeaders
  • producers::producer::KafkaProducerInterface

Macros

  • generate_event_dispatcher
  • kafka_admin
  • kafka_consumer
  • kafka_producer

Functions

  • messages::rdkafka_impl::borrowed_headers_to_headers
  • messages::rdkafka_impl::owned_headers_to_headers

Type Aliases

  • AdminImpl
  • ConsumerImpl
  • KafkaResult
  • ProducerImpl
  • messages::cloud_events::cloud_event::EventType
  • messages::kafka_message::HeaderKey
  • messages::kafka_message::HeaderValue
  • messages::kafka_message::Headers