Skip to content

Commit 2c05227

Browse files
LOGBROKER-8840: add CreateTopics endpoint to KafkaAPI (#747)
1 parent f5c9d26 commit 2c05227

File tree

10 files changed

+1907
-0
lines changed

10 files changed

+1907
-0
lines changed

ydb/core/kafka_proxy/actors/actors.h

Lines changed: 1 addition & 0 deletions
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)