Here's an example Python application using FastStream that consumes data from a
topic, increments the value, and outputs the data to another topic.
Save it in a file called basic.py.
frompydanticimportBaseModel,Field,NonNegativeFloatfromfaststreamimportFastStream,Loggerfromfaststream.kafkaimportKafkaBrokerfromfaststream.specificationimportAsyncAPIclassDataBasic(BaseModel):data:NonNegativeFloat=Field(...,examples=[0.5],description="Float data example",)broker=KafkaBroker("localhost:9092")app=FastStream(broker,specification=AsyncAPI(),)@broker.publisher("output_data")@broker.subscriber("input_data")asyncdefon_input_data(msg:DataBasic,logger:Logger)->DataBasic:logger.info(msg)returnDataBasic(data=msg.data+1.0)