Lars LehtonenandGitHub 75c807b586 chore(weed/mq/kafka/protocol): remove unused functions and variables (#9488)

2026-05-13 13:59:24 -07:00

..

batch_crc_compat_test.go

Add Kafka Gateway (#7231)

2025-10-13 18:05:17 -07:00

consumer_coordination.go

chore(weed/mq/kafka/protocol): remove unused functions and variables (#9488)

2026-05-13 13:59:24 -07:00

consumer_group_metadata.go

Fixes for kafka gateway (#7329)

2025-10-17 20:49:47 -07:00

debug_state.go

debug(kafka): add restart flake diagnostics

2026-04-24 15:02:07 -07:00

describe_cluster.go

go fmt

2025-10-27 23:04:55 -07:00

errors.go

go fmt

2026-04-10 17:31:14 -07:00

fetch_multibatch.go

Clean up logs and deprecated functions (#7339)

2025-10-17 22:11:50 -07:00

fetch_partition_reader.go

debug(kafka): add restart flake diagnostics

2026-04-24 15:02:07 -07:00

fetch.go

chore(weed/mq/kafka/protocol): prune dead code (#9288)

2026-04-29 14:11:37 -07:00

find_coordinator.go

Fixes for kafka gateway (#7329)

2025-10-17 20:49:47 -07:00

flexible_versions.go

go fmt

2025-10-27 23:04:55 -07:00

group_introspection.go

go fmt

2025-10-27 23:04:55 -07:00

handler.go

chore(weed/mq/kafka/protocol): remove unused functions and variables (#9488)

2026-05-13 13:59:24 -07:00

heartbeat_response_format_test.go

Fixes for kafka gateway (#7329)

2025-10-17 20:49:47 -07:00

joingroup.go

fix(kafka): evict expired group members on rejoin to unblock fast restart (#9243)

2026-04-27 09:43:55 -07:00

metadata_blocking_test.go

Fixes for kafka gateway (#7329)

2025-10-17 20:49:47 -07:00

metrics.go

Add Kafka Gateway (#7231)

2025-10-13 18:05:17 -07:00

offset_fetch_pattern_test.go

chore(weed/mq/kafka/protocol): remove unused functions and variables (#9488)

2026-05-13 13:59:24 -07:00

offset_management.go

Fixes for kafka gateway (#7329)

2025-10-17 20:49:47 -07:00

offset_storage_adapter.go

go fmt

2025-10-27 23:04:55 -07:00

produce.go

chore(weed/mq/kafka/protocol): prune dead code (#9016)

2026-04-10 11:51:57 -07:00

record_batch_parser_test.go

Add Kafka Gateway (#7231)

2025-10-13 18:05:17 -07:00

record_batch_parser.go

Add Kafka Gateway (#7231)

2025-10-13 18:05:17 -07:00

record_extraction_test.go

Add Kafka Gateway (#7231)

2025-10-13 18:05:17 -07:00

response_cache.go

Add Kafka Gateway (#7231)

2025-10-13 18:05:17 -07:00

response_format_test.go

Add Kafka Gateway (#7231)

2025-10-13 18:05:17 -07:00

response_validation_example_test.go

chore(weed/mq/kafka/protocol): remove unused functions and variables (#9488)

2026-05-13 13:59:24 -07:00

syncgroup_assignment_test.go

fix(kafka): close late-joiner orphan race in consumer-group rebalance (#9162)

2026-04-20 18:44:16 -07:00