From f07a5191525c2e8ee0d129f03c13cf89e93336db Mon Sep 17 00:00:00 2001 From: KunoVonHagen <41991675+KunoVonHagen@users.noreply.github.com> Date: Tue, 2 Jun 2026 13:42:10 +0200 Subject: [PATCH] Made client ready for first release --- Cargo.toml | 2 +- src/config.rs | 1 - src/consumer.rs | 5 +---- 3 files changed, 2 insertions(+), 6 deletions(-) diff --git a/Cargo.toml b/Cargo.toml index 02c0818..20c6d23 100644 --- a/Cargo.toml +++ b/Cargo.toml @@ -1,6 +1,6 @@ [package] name = "fluvio-client-cpp" -version = "0.0.2" +version = "0.1.0" edition = "2024" [lib] diff --git a/src/config.rs b/src/config.rs index a18d223..bb547ca 100644 --- a/src/config.rs +++ b/src/config.rs @@ -1,4 +1,3 @@ -use std::ops::DerefMut; use fluvio::FluvioConfig as FluvioConfigNative; use fluvio::consumer::ConsumerConfigBuilder as ConsumerConfigBuilderNative; use fluvio::TopicProducerConfigBuilder as TopicProducerConfigBuilderNative; diff --git a/src/consumer.rs b/src/consumer.rs index 041a1f7..eb0ee1c 100644 --- a/src/consumer.rs +++ b/src/consumer.rs @@ -1,14 +1,11 @@ use fluvio::{ - Offset as OffsetNative, - consumer::Record as NativeRecord, - consumer::ConsumerConfigExtBuilder as ConsumerConfigExtBuilderNative, + consumer::Record as NativeRecord }; use fluvio_future::task::run_block_on; use futures_util::stream::StreamExt; use futures_util::stream::Stream; use std::pin::Pin; use fluvio::dataplane::link::ErrorCode; -use crate::client::Fluvio; pub struct Record { pub inner: NativeRecord }