@@ -123,6 +123,14 @@ search:
123
123
- asyncapi
124
124
- [ get_app_schema] ( public_api/faststream/asyncapi/get_app_schema.md )
125
125
- [ get_asyncapi_html] ( public_api/faststream/asyncapi/get_asyncapi_html.md )
126
+ - confluent
127
+ - [ KafkaBroker] ( public_api/faststream/confluent/KafkaBroker.md )
128
+ - [ KafkaPublisher] ( public_api/faststream/confluent/KafkaPublisher.md )
129
+ - [ KafkaResponse] ( public_api/faststream/confluent/KafkaResponse.md )
130
+ - [ KafkaRoute] ( public_api/faststream/confluent/KafkaRoute.md )
131
+ - [ KafkaRouter] ( public_api/faststream/confluent/KafkaRouter.md )
132
+ - [ TestApp] ( public_api/faststream/confluent/TestApp.md )
133
+ - [ TestKafkaBroker] ( public_api/faststream/confluent/TestKafkaBroker.md )
126
134
- kafka
127
135
- [ KafkaBroker] ( public_api/faststream/kafka/KafkaBroker.md )
128
136
- [ KafkaPublisher] ( public_api/faststream/kafka/KafkaPublisher.md )
@@ -413,6 +421,101 @@ search:
413
421
- parser
414
422
- [ parse_cli_args] ( api/faststream/cli/utils/parser/parse_cli_args.md )
415
423
- [ remove_prefix] ( api/faststream/cli/utils/parser/remove_prefix.md )
424
+ - confluent
425
+ - [ KafkaBroker] ( api/faststream/confluent/KafkaBroker.md )
426
+ - [ KafkaPublisher] ( api/faststream/confluent/KafkaPublisher.md )
427
+ - [ KafkaResponse] ( api/faststream/confluent/KafkaResponse.md )
428
+ - [ KafkaRoute] ( api/faststream/confluent/KafkaRoute.md )
429
+ - [ KafkaRouter] ( api/faststream/confluent/KafkaRouter.md )
430
+ - [ TestApp] ( api/faststream/confluent/TestApp.md )
431
+ - [ TestKafkaBroker] ( api/faststream/confluent/TestKafkaBroker.md )
432
+ - broker
433
+ - [ KafkaBroker] ( api/faststream/confluent/broker/KafkaBroker.md )
434
+ - broker
435
+ - [ KafkaBroker] ( api/faststream/confluent/broker/broker/KafkaBroker.md )
436
+ - logging
437
+ - [ KafkaLoggingBroker] ( api/faststream/confluent/broker/logging/KafkaLoggingBroker.md )
438
+ - registrator
439
+ - [ KafkaRegistrator] ( api/faststream/confluent/broker/registrator/KafkaRegistrator.md )
440
+ - client
441
+ - [ AsyncConfluentConsumer] ( api/faststream/confluent/client/AsyncConfluentConsumer.md )
442
+ - [ AsyncConfluentProducer] ( api/faststream/confluent/client/AsyncConfluentProducer.md )
443
+ - [ BatchBuilder] ( api/faststream/confluent/client/BatchBuilder.md )
444
+ - [ MsgToSend] ( api/faststream/confluent/client/MsgToSend.md )
445
+ - [ TopicPartition] ( api/faststream/confluent/client/TopicPartition.md )
446
+ - [ check_msg_error] ( api/faststream/confluent/client/check_msg_error.md )
447
+ - [ create_topics] ( api/faststream/confluent/client/create_topics.md )
448
+ - config
449
+ - [ BrokerAddressFamily] ( api/faststream/confluent/config/BrokerAddressFamily.md )
450
+ - [ BuiltinFeatures] ( api/faststream/confluent/config/BuiltinFeatures.md )
451
+ - [ ClientDNSLookup] ( api/faststream/confluent/config/ClientDNSLookup.md )
452
+ - [ CompressionCodec] ( api/faststream/confluent/config/CompressionCodec.md )
453
+ - [ CompressionType] ( api/faststream/confluent/config/CompressionType.md )
454
+ - [ ConfluentConfig] ( api/faststream/confluent/config/ConfluentConfig.md )
455
+ - [ Debug] ( api/faststream/confluent/config/Debug.md )
456
+ - [ GroupProtocol] ( api/faststream/confluent/config/GroupProtocol.md )
457
+ - [ IsolationLevel] ( api/faststream/confluent/config/IsolationLevel.md )
458
+ - [ OffsetStoreMethod] ( api/faststream/confluent/config/OffsetStoreMethod.md )
459
+ - [ SASLOAUTHBearerMethod] ( api/faststream/confluent/config/SASLOAUTHBearerMethod.md )
460
+ - [ SecurityProtocol] ( api/faststream/confluent/config/SecurityProtocol.md )
461
+ - fastapi
462
+ - [ Context] ( api/faststream/confluent/fastapi/Context.md )
463
+ - [ KafkaRouter] ( api/faststream/confluent/fastapi/KafkaRouter.md )
464
+ - fastapi
465
+ - [ KafkaRouter] ( api/faststream/confluent/fastapi/fastapi/KafkaRouter.md )
466
+ - message
467
+ - [ ConsumerProtocol] ( api/faststream/confluent/message/ConsumerProtocol.md )
468
+ - [ FakeConsumer] ( api/faststream/confluent/message/FakeConsumer.md )
469
+ - [ KafkaMessage] ( api/faststream/confluent/message/KafkaMessage.md )
470
+ - opentelemetry
471
+ - [ KafkaTelemetryMiddleware] ( api/faststream/confluent/opentelemetry/KafkaTelemetryMiddleware.md )
472
+ - middleware
473
+ - [ KafkaTelemetryMiddleware] ( api/faststream/confluent/opentelemetry/middleware/KafkaTelemetryMiddleware.md )
474
+ - provider
475
+ - [ BaseConfluentTelemetrySettingsProvider] ( api/faststream/confluent/opentelemetry/provider/BaseConfluentTelemetrySettingsProvider.md )
476
+ - [ BatchConfluentTelemetrySettingsProvider] ( api/faststream/confluent/opentelemetry/provider/BatchConfluentTelemetrySettingsProvider.md )
477
+ - [ ConfluentTelemetrySettingsProvider] ( api/faststream/confluent/opentelemetry/provider/ConfluentTelemetrySettingsProvider.md )
478
+ - [ telemetry_attributes_provider_factory] ( api/faststream/confluent/opentelemetry/provider/telemetry_attributes_provider_factory.md )
479
+ - parser
480
+ - [ AsyncConfluentParser] ( api/faststream/confluent/parser/AsyncConfluentParser.md )
481
+ - publisher
482
+ - asyncapi
483
+ - [ AsyncAPIBatchPublisher] ( api/faststream/confluent/publisher/asyncapi/AsyncAPIBatchPublisher.md )
484
+ - [ AsyncAPIDefaultPublisher] ( api/faststream/confluent/publisher/asyncapi/AsyncAPIDefaultPublisher.md )
485
+ - [ AsyncAPIPublisher] ( api/faststream/confluent/publisher/asyncapi/AsyncAPIPublisher.md )
486
+ - producer
487
+ - [ AsyncConfluentFastProducer] ( api/faststream/confluent/publisher/producer/AsyncConfluentFastProducer.md )
488
+ - usecase
489
+ - [ BatchPublisher] ( api/faststream/confluent/publisher/usecase/BatchPublisher.md )
490
+ - [ DefaultPublisher] ( api/faststream/confluent/publisher/usecase/DefaultPublisher.md )
491
+ - [ LogicPublisher] ( api/faststream/confluent/publisher/usecase/LogicPublisher.md )
492
+ - response
493
+ - [ KafkaResponse] ( api/faststream/confluent/response/KafkaResponse.md )
494
+ - router
495
+ - [ KafkaPublisher] ( api/faststream/confluent/router/KafkaPublisher.md )
496
+ - [ KafkaRoute] ( api/faststream/confluent/router/KafkaRoute.md )
497
+ - [ KafkaRouter] ( api/faststream/confluent/router/KafkaRouter.md )
498
+ - schemas
499
+ - params
500
+ - [ ConsumerConnectionParams] ( api/faststream/confluent/schemas/params/ConsumerConnectionParams.md )
501
+ - security
502
+ - [ parse_security] ( api/faststream/confluent/security/parse_security.md )
503
+ - subscriber
504
+ - asyncapi
505
+ - [ AsyncAPIBatchSubscriber] ( api/faststream/confluent/subscriber/asyncapi/AsyncAPIBatchSubscriber.md )
506
+ - [ AsyncAPIDefaultSubscriber] ( api/faststream/confluent/subscriber/asyncapi/AsyncAPIDefaultSubscriber.md )
507
+ - [ AsyncAPISubscriber] ( api/faststream/confluent/subscriber/asyncapi/AsyncAPISubscriber.md )
508
+ - factory
509
+ - [ create_subscriber] ( api/faststream/confluent/subscriber/factory/create_subscriber.md )
510
+ - usecase
511
+ - [ BatchSubscriber] ( api/faststream/confluent/subscriber/usecase/BatchSubscriber.md )
512
+ - [ DefaultSubscriber] ( api/faststream/confluent/subscriber/usecase/DefaultSubscriber.md )
513
+ - [ LogicSubscriber] ( api/faststream/confluent/subscriber/usecase/LogicSubscriber.md )
514
+ - testing
515
+ - [ FakeProducer] ( api/faststream/confluent/testing/FakeProducer.md )
516
+ - [ MockConfluentMessage] ( api/faststream/confluent/testing/MockConfluentMessage.md )
517
+ - [ TestKafkaBroker] ( api/faststream/confluent/testing/TestKafkaBroker.md )
518
+ - [ build_message] ( api/faststream/confluent/testing/build_message.md )
416
519
- constants
417
520
- [ ContentTypes] ( api/faststream/constants/ContentTypes.md )
418
521
- exceptions
0 commit comments