Record · corpus.blog/posts/01a08751-642f-72f8-82ab-23ae7e1efdc1

Route, Layer and Process Kafka Messages with Nisshi Services

blog.nisshi.io · published 3 September 2025

A record is what was published and who pointed at it. The text of the post is not held here: read it at the source, or at its Wayback capture.

Read the post at blog.nisshi.io Wayback capture

0blogs citing

First cited: —
Most recent: —
Rank this month: not ranked
Links from this post: 42
Words captured: 2,218

Cited by

No blog we hold has cited this post yet.

Links from this post

Link

Host

Inventing the Service trait Read at the source ↗

tokio.rs

https://docs.rs/nisshi-service/latest/nisshi_service/struct.TcpListenerLayer.html

docs.rs

https://docs.rs/tokio-util/latest/tokio_util/sync/struct.CancellationToken.html

docs.rs

https://docs.rs/tokio/latest/tokio/task/struct.JoinSet.html

docs.rs

https://docs.rs/nisshi-service/latest/nisshi_service/struct.TcpContextLayer.html

docs.rs

https://docs.rs/nisshi-service/latest/nisshi_service/struct.TcpBytesLayer.html

docs.rs

https://docs.rs/bytes/latest/bytes/struct.Bytes.html

docs.rs

https://docs.rs/tokio/latest/tokio/net/struct.TcpStream.html

docs.rs

https://docs.rs/nisshi-service/latest/nisshi_service/struct.BytesFrameLayer.html

docs.rs

https://kafka.apache.org

kafka.apache.org

https://docs.rs/nisshi-sans-io/latest/nisshi_sans_io/struct.Frame.html

docs.rs

https://docs.rs/nisshi-service/latest/nisshi_service/struct.BytesFrameService.html

docs.rs

https://nisshi.io

nisshi.io

https://serde.rs

serde.rs

https://doc.rust-lang.org/reference/procedural-macros.html

doc.rust-lang.org

https://github.com/apache/kafka/tree/trunk/clients/src/main/resources/common/message

github.com

Protocol Read at the source ↗

kafka.apache.org

https://serde.rs/data-model.html

serde.rs

https://docs.rs/nisshi-service/latest/nisshi_service/struct.FrameRouteService.html

docs.rs

https://docs.rs/nisshi-sans-io/latest/nisshi_sans_io/trait.Request.html

docs.rs

https://docs.rs/nisshi-sans-io/latest/nisshi_sans_io/metadata_request/struct.MetadataRequest.html

docs.rs

https://docs.rs/nisshi-storage/latest/nisshi_storage/enum.StorageContainer.html

docs.rs

https://docs.rs/nisshi-storage/latest/nisshi_storage/trait.Storage.html

docs.rs

https://docs.rs/nisshi-storage/latest/nisshi_storage/index.html

docs.rs

https://docs.rs/nisshi-service/latest/nisshi_service/struct.FrameRouteBuilder.html

docs.rs

https://docs.rs/nisshi-storage/latest/nisshi_storage/struct.MetadataService.html

docs.rs

https://docs.rs/rama/latest/rama/layer/struct.MapStateLayer.html

docs.rs

https://docs.rs/nisshi-sans-io/latest/nisshi_sans_io/api_versions_request/struct.ApiVersionsRequest.html

docs.rs

https://docs.rs/nisshi-sans-io/latest/nisshi_sans_io/api_versions_response/struct.ApiVersionsResponse.html

docs.rs

https://docs.rs/nisshi-sans-io/latest/nisshi_sans_io/struct.RootMessageMeta.html

docs.rs

https://docs.rs/nisshi-service/latest/nisshi_service/struct.ConnectionManager.html

docs.rs

https://docs.rs/nisshi-client/latest/nisshi_client/type.Pool.html

docs.rs

https://docs.rs/nisshi-client/latest/nisshi_client/struct.Connection.html

docs.rs

https://docs.rs/nisshi-client/latest/nisshi_client/struct.RequestPoolLayer.html

docs.rs

https://docs.rs/nisshi-client/latest/nisshi_client/struct.RequestConnectionLayer.html

docs.rs

https://docs.rs/nisshi-service/latest/nisshi_service/struct.FrameBytesLayer.html

docs.rs

https://docs.rs/nisshi-client/latest/nisshi_client/struct.BytesConnectionService.html

docs.rs

https://docs.rs/nisshi-sans-io/latest/nisshi_sans_io/metadata_response/struct.MetadataResponse.html

docs.rs

https://docs.rs/rama/latest/rama/trait.Service.html

docs.rs

https://docs.rs/rama/latest/rama/trait.Layer.html

docs.rs

https://crates.io/search?q=nisshi

crates.io

https://docs.rs/releases/search?query=nisshi

docs.rs