Skip to content

Commit 4898c80

Browse files
siarheivesialouadameat
authored andcommitted
LOGBROKER-8840: add CreateTopics endpoint to KafkaAPI (ydb-platform#747)
1 parent 53096ff commit 4898c80

10 files changed

+1907
-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)