Skip to content

Commit 8d6e1c8

Browse files
LOGBROKER-8840: add CreateTopics endpoint to KafkaAPI
1 parent f59afad commit 8d6e1c8

9 files changed

+1894
-0
lines changed

ydb/core/kafka_proxy/actors/actors.h

+1
Original file line numberDiff line numberDiff line change
@@ -158,5 +158,6 @@ NActors::IActor* CreateKafkaFetchActor(const TContext::TPtr context, const ui64
158158
NActors::IActor* CreateKafkaFindCoordinatorActor(const TContext::TPtr context, const ui64 correlationId, const TMessagePtr<TFindCoordinatorRequestData>& message);
159159
NActors::IActor* CreateKafkaOffsetCommitActor(const TContext::TPtr context, const ui64 correlationId, const TMessagePtr<TOffsetCommitRequestData>& message);
160160
NActors::IActor* CreateKafkaOffsetFetchActor(const TContext::TPtr context, const ui64 correlationId, const TMessagePtr<TOffsetFetchRequestData>& message);
161+
NActors::IActor* CreateKafkaCreateTopicsActor(const TContext::TPtr context, const ui64 correlationId, const TMessagePtr<TCreateTopicsRequestData>& message);
161162

162163
} // namespace NKafka

0 commit comments

Comments
 (0)