LOGBROKER-8840: add CreateTopics endpoint to KafkaAPI

siarheivesialou · Dec 28, 2023 · 95346b4 · 95346b4
1 parent f59afad
commit 95346b4
Show file tree

Hide file tree

Showing 10 changed files with 1,907 additions and 0 deletions.
diff --git a/ydb/core/kafka_proxy/actors/actors.h b/ydb/core/kafka_proxy/actors/actors.h
@@ -158,5 +158,6 @@ NActors::IActor* CreateKafkaFetchActor(const TContext::TPtr context, const ui64
 NActors::IActor* CreateKafkaFindCoordinatorActor(const TContext::TPtr context, const ui64 correlationId, const TMessagePtr<TFindCoordinatorRequestData>& message);
 NActors::IActor* CreateKafkaOffsetCommitActor(const TContext::TPtr context, const ui64 correlationId, const TMessagePtr<TOffsetCommitRequestData>& message);
 NActors::IActor* CreateKafkaOffsetFetchActor(const TContext::TPtr context, const ui64 correlationId, const TMessagePtr<TOffsetFetchRequestData>& message);
+NActors::IActor* CreateKafkaCreateTopicsActor(const TContext::TPtr context, const ui64 correlationId, const TMessagePtr<TCreateTopicsRequestData>& message);
 
 } // namespace NKafka