Skip to content

Commit

Permalink
docs: fix serialization page code example tabulation (kpn#184)
Browse files Browse the repository at this point in the history
  • Loading branch information
Lancetnik authored May 31, 2024
1 parent 2997ca0 commit 8f88508
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions docs/serialization.md
Original file line number Diff line number Diff line change
Expand Up @@ -71,10 +71,10 @@ from kstreams import middleware, ConsumerRecord


@stream_engine.stream(topic, middlewares=[middleware.Middleware(JsonDeserializerMiddleware)])
async def hello_stream(cr: ConsumerRecord):
# remember event.value is now a dict
print(cr.value["message"])
save_to_db(cr)
async def hello_stream(cr: ConsumerRecord):
# remember event.value is now a dict
print(cr.value["message"])
save_to_db(cr)
```

```python
Expand Down

0 comments on commit 8f88508

Please sign in to comment.