MyRocks (MySql)와 Cassandra는 모두 LSM 아키텍처를 사용하여 데이터를 저장합니다. 그래서 MySolve는 스토리지 엔진으로 Cassandra에서 MyRocks로 약 5 백만 행을 채 웁니다. Cassandra의 경우 스토리지 공간이 MyRocks 인 MySql은 디스크 공간이 1.7GB 밖에되지 않으며 19GB가 필요합니다. 내가 누락
개발 용 Windows 컴퓨터에 Kafka Streams 응용 프로그램을 쓰고 있습니다. 나는 단지 응용 프로그램을 실행할 때 다음 오류 얻을 카프카 스트림의 leftJoin 및 branch 기능을 사용하려고하면 : 그것은 카프카처럼 보인다 Exception in thread "StreamThread-1" java.lang.UnsatisfiedLinkErr
슬레이브에서 Percona MyRocks 스토리지 엔진을 선택하고 Innodb 엔진을 실행하는 Galera Cluster를 복제하면 아무에게도 조언을 제공 할 수 없습니다. 그러한 복제가 작동 할 것인가? 그렇다면 Pt-schema-change를 통해 Galera 클러스터에서 스키마 변경이 이루어질 가능성은 어느 정도인가?
Kafka Streams에서 JoinWindow를 사용하여 스트림/스트림 조인을 사용하고 있습니다. 내가 이해할 수있는 것으로부터, JoinWindows는 Stores를 사용하여 구현되고 두 스트림의 데이터는 모두 RocksDB 데이터베이스에 저장됩니다. 그러나 이벤트 시간이 만료되면 (에 정의 된 보존 시간을 ()까지 전달하면 실제 데이터는 어떻게됩니까?
저급 프로세서 API를 실험 해보았습니다. 들어오는 레코드에 대한 데이터 집계는 프로세서 API를 사용하고 집계 된 레코드를 RocksDB에 쓰고 있습니다. 그러나 rocksdb에 추가 된 레코드를 24 시간 동안 만 활성 상태로 유지하려고합니다. 24 시간이 지나면 기록을 삭제해야합니다. 이것은 ttl 설정을 변경하여 수행 할 수 있습니다. 그러나, 이것
내 kafka-streams DSL의 끝에 Transformer 사용자 지정이 있으며 영구 변경 로그 KeyValueStore이 바인딩되어 있습니다. 몇 주 전부터 상점에 너무 많은 데이터를 넣었습니다. 이제는 응용 프로그램을로드 할 때마다 너무 많은 RAM을 먹습니다. 그러나 응용 프로그램 자체는 단지 프로토 타입이므로 저장소를 완전히 지우는 데는 신경
하나의 응용 프로그램에서 사용하고있는 RocksDB 데이터에 대해 안심할 수있는 암호화를 구현하는 옵션을 모색 중입니다. 즉, 데이터에 키를 저장할 필요가 없으며 런타임에 계산할 수 있습니다). 이상적으로는 DES이어야합니다. RocksDB 전용 플러그인이나 라이브러리가 있습니까? 아니면 즉석에서해야합니까?
RocksDB newbie here. 런타임시 나는 에 대해서만 RocksDB를 사용하여 데이터을 읽습니다. 때로는 다른 소스의 세션 특정 레코드를 병합해야합니다. 주 데이터베이스에 병합하지 않기를 바랍니다. 특정 세션의 세션 수명 동안 만 존재하도록하고 싶습니다. 물론 정규 std :: vector를 사용하여 RocksDB와 다른 소스를 병합 할 수 있지