Skip to content

Change Data Capture (CDC) support #13

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
xaka opened this issue Apr 19, 2022 · 2 comments
Closed

Change Data Capture (CDC) support #13

xaka opened this issue Apr 19, 2022 · 2 comments
Labels
area/datashard Issues related to datashard tablets (relational table partitions) enhancement New feature or request

Comments

@xaka
Copy link

xaka commented Apr 19, 2022

Does YDB support CDC or any other mechanism to stream data changes to Kafka, etc.?

@fomichev3000 fomichev3000 added enhancement New feature or request area/datashard Issues related to datashard tablets (relational table partitions) labels May 18, 2022
@fomichev3000
Copy link
Member

We are working on this feature.

@alexv-smirnov
Copy link
Member

The feature is now available as part of the 22-4 stable release. Please visit https://ydb.tech/en/docs/concepts/cdc for details.

Events are written to a topic:
https://ydb.tech/en/docs/concepts/topic (concepts)
https://ydb.tech/en/docs/reference/ydb-cli/topic-overview (CLI)
https://ydb.tech/en/docs/reference/ydb-sdk/topic (Go SDK)

Sazonov99 added a commit to Sazonov99/ydb that referenced this issue May 5, 2025
/place/sandbox-data/tasks/8/8/3053489088/__FUSE/mount_path_85659d51-ce9b-4cfe-bbaa-40809fb5ff23/contrib/ydb/core/util/cpuinfo.cpp:108:32: runtime error: -nan is outside the range of representable values of type 'unsigned int'
    #0 0x35c666d6 in NKikimr::TSystemThreadsMonitor::GetThreadPools(TInstant) /-S/contrib/ydb/core/util/cpuinfo.cpp:108:32
    ydb-platform#1 0x35c0d648 in NKikimr::NNodeWhiteboard::TNodeWhiteboardService::Handle(TAutoPtr<NActors::TEventHandle<NKikimr::NNodeWhiteboard::TNodeWhiteboardService::TEvPrivate::TEvUpdateRuntimeStats>, TDelete>&, NActors::TActorContext const&) /-S/contrib/ydb/core/tablet/node_whiteboard.cpp:1152:43
    ydb-platform#2 0x35bfa08c in NKikimr::NNodeWhiteboard::TNodeWhiteboardService::StateFunc(TAutoPtr<NActors::IEventHandle, TDelete>&) /-S/contrib/ydb/core/tablet/node_whiteboard.cpp:526:5
    ydb-platform#3 0x16ebbd43 in NActors::IActor::Receive(TAutoPtr<NActors::IEventHandle, TDelete>&) /-S/contrib/ydb/library/actors/core/actor.cpp:280:13
    ydb-platform#4 0x331e74cb in NActors::TTestActorRuntimeBase::SendInternal(TAutoPtr<NActors::IEventHandle, TDelete>, unsigned int, bool) /-S/contrib/ydb/library/actors/testlib/test_runtime.cpp:1702:33
    ydb-platform#5 0x331dfe6a in NActors::TTestActorRuntimeBase::DispatchEventsInternal(NActors::TDispatchOptions const&, TInstant) /-S/contrib/ydb/library/actors/testlib/test_runtime.cpp:1295:45
    ydb-platform#6 0x331dd77e in NActors::TTestActorRuntimeBase::DispatchEvents(NActors::TDispatchOptions const&, TInstant) /-S/contrib/ydb/library/actors/testlib/test_runtime.cpp:1091:16
    ydb-platform#7 0x1203075c in NCloud::NStorage::(anonymous namespace)::BootHiveMock(NActors::TTestActorRuntime&, unsigned long, TIntrusivePtr<NCloud::NStorage::(anonymous namespace)::THiveMockState, TDefaultIntrusivePtrOps<NCloud::NStorage::(anonymous namespace)::THiveMockState>>, NCloud::NStorage::(anonymous namespace)::EExternalBootOptions) /-S/cloud/storage/core/libs/hive_proxy/hive_proxy_ut.cpp:415:17
    ydb-platform#8 0x11fe3d57 in NCloud::NStorage::(anonymous namespace)::TTestEnv::TTestEnv(NActors::TTestActorRuntime&, TBasicString<char, std::__y1::char_traits<char>>, bool, bool, bool) /-S/cloud/storage/core/libs/hive_proxy/hive_proxy_ut.cpp:447:9
    ydb-platform#9 0x11fef7e7 in NCloud::NStorage::NTestSuiteTHiveProxyTest::TTestCaseLockReconnected::Execute_(NUnitTest::TTestContext&) /-S/cloud/storage/core/libs/hive_proxy/hive_proxy_ut.cpp:909:18
    ydb-platform#10 0x1202d38f in NCloud::NStorage::NTestSuiteTHiveProxyTest::TCurrentTest::Execute()::'lambda'()::operator()() const /-S/cloud/storage/core/libs/hive_proxy/hive_proxy_ut.cpp:802:1
    ydb-platform#11 0x12545679 in NUnitTest::TTestBase::Run(std::__y1::function<void ()>, TBasicString<char, std::__y1::char_traits<char>> const&, char const*, bool) /-S/library/cpp/testing/unittest/registar.cpp:373:18
    ydb-platform#12 0x1202b74f in NCloud::NStorage::NTestSuiteTHiveProxyTest::TCurrentTest::Execute() /-S/cloud/storage/core/libs/hive_proxy/hive_proxy_ut.cpp:802:1
    ydb-platform#13 0x12547045 in NUnitTest::TTestFactory::Execute() /-S/library/cpp/testing/unittest/registar.cpp:494:19
    ydb-platform#14 0x1256700c in NUnitTest::RunMain(int, char**) /-S/library/cpp/testing/unittest/utmain.cpp:872:44
    ydb-platform#15 0x7f582a8d8082 in __libc_start_main (/lib/x86_64-linux-gnu/libc.so.6+0x24082) (BuildId: 1878e6b475720c7c51969e69ab2d276fae6d1dee)
    ydb-platform#16 0x1001f028 in _start (/tmp/3053489088/tmpscdMvC/build_root/fxqa/007ce8/cloud/storage/core/libs/hive_proxy/ut/cloud-storage-core-libs-hive_proxy-ut+0x1001f028) (BuildId: 6ff85f4ee4c5af508adb6bac1d7e58f9d8052d10)
SUMMARY: UndefinedBehaviorSanitizer: undefined-behavior /place/sandbox-data/tasks/8/8/3053489088/__FUSE/mount_path_85659d51-ce9b-4cfe-bbaa-40809fb5ff23/contrib/ydb/core/util/cpuinfo.cpp:108:32
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
area/datashard Issues related to datashard tablets (relational table partitions) enhancement New feature or request
Projects
None yet
Development

No branches or pull requests

3 participants