zeekayandHanzo Dev b08db2f70a Serve a listener the host hands over: Connect, then Accept ...

Serve is now Connect (dial the bus, ensure the offset bucket, watch tails,
bound partitions, start admin) followed by a TCP listener and Accept on it,
with the same behaviour as before. A host that owns the Kafka port itself
calls Connect, which fails as soon as the bus refuses rather than after a
startup timer, and then Accept on a unix socket it relays to. Metadata and
FindCoordinator keep advertising Config.BrokerHost:BrokerPort, never the
listener's own address.

Accept closes a listener that a Shutdown before it never saw, and returns
the error when its listener is closed by anything but Shutdown instead of
retrying a dead socket.

Co-authored-by: Hanzo Dev <[email protected]>

2026-10-03 15:51:27 -07:00

..

accept_test.go

Serve a listener the host hands over: Connect, then Accept

2026-10-03 15:51:27 -07:00

admin.go

Hanzo Kafka: one name for the Kafka-wire adaptor

2026-07-30 06:02:35 -07:00

api_versions.go

e2e: a real Kafka client against the real store, in one process

2026-07-30 06:33:39 -07:00

broker.go

Serve a listener the host hands over: Connect, then Accept

2026-10-03 15:51:27 -07:00

create_topic.go

Bound topic partitions by age and size

2026-09-24 09:27:41 -07:00

describe_configs.go

Hanzo Kafka: one name for the Kafka-wire adaptor

2026-07-30 06:02:35 -07:00

dispatcher.go

e2e: a real Kafka client against the real store, in one process

2026-07-30 06:33:39 -07:00

error.go

broker: offsets from batch headers only — sparse-sequence correct, poison-proof

2026-07-30 06:26:08 -07:00

fetch_test.go

Read a partition's tail by subject; fail bounds on a failed read

2026-10-03 12:27:12 -07:00

fetch.go

Hold caught-up fetches for MaxWaitMs and cache partition bounds

2026-10-03 12:25:33 -07:00

find_coordinator.go

e2e: a real Kafka client against the real store, in one process

2026-07-30 06:33:39 -07:00

harness_test.go

Hold caught-up fetches for MaxWaitMs and cache partition bounds

2026-10-03 12:25:33 -07:00

idle_test.go

Hold caught-up fetches for MaxWaitMs and cache partition bounds

2026-10-03 12:25:33 -07:00

metadata.go

Bound topic partitions by age and size

2026-09-24 09:27:41 -07:00

produce.go

Hold caught-up fetches for MaxWaitMs and cache partition bounds

2026-10-03 12:25:33 -07:00

recordbatch.go

broker: offsets from batch headers only — sparse-sequence correct, poison-proof

2026-07-30 06:26:08 -07:00

responses.go

Hold caught-up fetches for MaxWaitMs and cache partition bounds

2026-10-03 12:25:33 -07:00

serve_test.go

broker: offsets from batch headers only — sparse-sequence correct, poison-proof

2026-07-30 06:26:08 -07:00

types.go

broker: offsets from batch headers only — sparse-sequence correct, poison-proof

2026-07-30 06:26:08 -07:00