Skip to content

Commit f07a519

Browse files
committed
Made client ready for first release
1 parent e73ccfb commit f07a519

3 files changed

Lines changed: 2 additions & 6 deletions

File tree

Cargo.toml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
[package]
22
name = "fluvio-client-cpp"
3-
version = "0.0.2"
3+
version = "0.1.0"
44
edition = "2024"
55

66
[lib]

src/config.rs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,3 @@
1-
use std::ops::DerefMut;
21
use fluvio::FluvioConfig as FluvioConfigNative;
32
use fluvio::consumer::ConsumerConfigBuilder as ConsumerConfigBuilderNative;
43
use fluvio::TopicProducerConfigBuilder as TopicProducerConfigBuilderNative;

src/consumer.rs

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,14 +1,11 @@
11
use fluvio::{
2-
Offset as OffsetNative,
3-
consumer::Record as NativeRecord,
4-
consumer::ConsumerConfigExtBuilder as ConsumerConfigExtBuilderNative,
2+
consumer::Record as NativeRecord
53
};
64
use fluvio_future::task::run_block_on;
75
use futures_util::stream::StreamExt;
86
use futures_util::stream::Stream;
97
use std::pin::Pin;
108
use fluvio::dataplane::link::ErrorCode;
11-
use crate::client::Fluvio;
129

1310
pub struct Record { pub inner: NativeRecord }
1411

0 commit comments

Comments
 (0)