File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change 11[package ]
22name = " fluvio-client-cpp"
3- version = " 0.0.2 "
3+ version = " 0.1.0 "
44edition = " 2024"
55
66[lib ]
Original file line number Diff line number Diff line change 1- use std:: ops:: DerefMut ;
21use fluvio:: FluvioConfig as FluvioConfigNative ;
32use fluvio:: consumer:: ConsumerConfigBuilder as ConsumerConfigBuilderNative ;
43use fluvio:: TopicProducerConfigBuilder as TopicProducerConfigBuilderNative ;
Original file line number Diff line number Diff line change 11use fluvio:: {
2- Offset as OffsetNative ,
3- consumer:: Record as NativeRecord ,
4- consumer:: ConsumerConfigExtBuilder as ConsumerConfigExtBuilderNative ,
2+ consumer:: Record as NativeRecord
53} ;
64use fluvio_future:: task:: run_block_on;
75use futures_util:: stream:: StreamExt ;
86use futures_util:: stream:: Stream ;
97use std:: pin:: Pin ;
108use fluvio:: dataplane:: link:: ErrorCode ;
11- use crate :: client:: Fluvio ;
129
1310pub struct Record { pub inner : NativeRecord }
1411
You can’t perform that action at this time.
0 commit comments