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:04 UTC
(iggy) branch disable_validations created (now a2830779)
This is an automated email from the ASF dual-hosted git repository.
gkoszyk pushed a change to branch disable_validations
in repository https://gitbox.apache.org/repos/asf/iggy.git
at a2830779 feat(io_uring): disable validations for new architecture
This branch includes the following new commits:
new a2830779 feat(io_uring): disable validations for new architecture
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
(iggy) 01/01: feat(io_uring): disable validations for new architecture
Posted by gk...@apache.org.
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| {