You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iggy.apache.org by gk...@apache.org on 2025/08/05 14:36:05 UTC
(iggy) 01/01: feat(io_uring): disable validations for new architecture
This is an automated email from the ASF dual-hosted git repository.
gkoszyk pushed a commit to branch disable_validations
in repository https://gitbox.apache.org/repos/asf/iggy.git
commit a28307793dbf176f6f33dc9b647a73c3e6c3a767
Author: numminex <g....@gmail.com>
AuthorDate: Tue Aug 5 16:35:53 2025 +0200
feat(io_uring): disable validations for new architecture
---
core/server/src/shard/system/consumer_groups.rs | 2 +-
core/server/src/shard/system/topics.rs | 4 ++--
core/server/src/shard/system/utils.rs | 6 +++---
3 files changed, 6 insertions(+), 6 deletions(-)
diff --git a/core/server/src/shard/system/consumer_groups.rs b/core/server/src/shard/system/consumer_groups.rs
index 7f11aee1..79ea516e 100644
--- a/core/server/src/shard/system/consumer_groups.rs
+++ b/core/server/src/shard/system/consumer_groups.rs
@@ -227,7 +227,7 @@ impl IggyShard {
group_id: &Identifier,
) -> Result<consumer_group2::ConsumerGroup, IggyError> {
self.ensure_authenticated(session)?;
- self.ensure_consumer_group_exists(stream_id, topic_id, group_id)?;
+ //self.ensure_consumer_group_exists(stream_id, topic_id, group_id)?;
{
let topic_id = self
.streams2
diff --git a/core/server/src/shard/system/topics.rs b/core/server/src/shard/system/topics.rs
index 5e45b8fa..da411296 100644
--- a/core/server/src/shard/system/topics.rs
+++ b/core/server/src/shard/system/topics.rs
@@ -154,7 +154,7 @@ impl IggyShard {
stats: Arc<TopicStats>,
) -> Result<usize, IggyError> {
self.ensure_authenticated(session)?;
- self.ensure_stream_exists(stream_id)?;
+ //self.ensure_stream_exists(stream_id)?;
{
let stream_id = self
.streams2
@@ -392,7 +392,7 @@ impl IggyShard {
replication_factor: Option<u8>,
) -> Result<(), IggyError> {
self.ensure_authenticated(session)?;
- self.ensure_topic_exists(stream_id, topic_id)?;
+ //self.ensure_topic_exists(stream_id, topic_id)?;
{
let topic_id = self
.streams2
diff --git a/core/server/src/shard/system/utils.rs b/core/server/src/shard/system/utils.rs
index 3efdcabb..6ad3b224 100644
--- a/core/server/src/shard/system/utils.rs
+++ b/core/server/src/shard/system/utils.rs
@@ -15,7 +15,7 @@ impl IggyShard {
stream_id: &Identifier,
topic_id: &Identifier,
) -> Result<(), IggyError> {
- self.ensure_stream_exists(stream_id)?;
+ //self.ensure_stream_exists(stream_id)?;
let exists = self
.streams2
.with_stream_by_id(stream_id, |stream| stream.topics().exists(topic_id));
@@ -31,8 +31,8 @@ impl IggyShard {
topic_id: &Identifier,
group_id: &Identifier,
) -> Result<(), IggyError> {
- self.ensure_stream_exists(stream_id)?;
- self.ensure_topic_exists(stream_id, topic_id)?;
+ //self.ensure_stream_exists(stream_id)?;
+ //self.ensure_topic_exists(stream_id, topic_id)?;
let exists = self
.streams2
.with_topic_by_id(stream_id, topic_id, |topic| {