You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

Branch: feature/mq-kafka-gateway-m1

add-ec-vacuum

add-foundation-db

add_fasthttp_client

add_remote_storage

adding-message-queue-integration-tests

avoid_releasing_temp_file_on_write

changing-to-zap

collect-public-metrics

create-table-snapshot-api-design

data_query_pushdown

dependabot/maven/other/java/client/com.google.protobuf-protobuf-java-3.25.5

dependabot/maven/other/java/examples/org.apache.hadoop-hadoop-common-3.4.0

detect-and-plan-ec-tasks

do-not-retry-if-error-is-NotFound

fasthttp

feature/mq-kafka-gateway-m1

filer1_maintenance_branch

fix-GetObjectLockConfigurationHandler

fix-versioning-listing-only

ftp

gh-pages

improve-fuse-mount

improve-fuse-mount2

logrus

master

message_send

mount2

mq-subscribe

mq2

original_weed_mount

random_access_file

refactor-needle-read-operations

refactor-volume-write

remote_overlay

revert-5134-patch-1

revert-5819-patch-1

revert-6434-bugfix-missing-s3-audit

s3-select

sub

tcp_read

test-reverting-lock-table

test_udp

testing

testing-sdx-generation

tikv

track-mount-e2e

volume_buffered_writes

worker-execute-ec-tasks

0.72

0.72.release

0.73

0.74

0.75

0.76

0.77

0.90

0.91

0.92

0.93

0.94

0.95

0.96

0.97

0.98

0.99

1.00

1.01

1.02

1.03

1.04

1.05

1.06

1.07

1.08

1.09

1.10

1.11

1.12

1.14

1.15

1.16

1.17

1.18

1.19

1.20

1.21

1.22

1.23

1.24

1.25

1.26

1.27

1.28

1.29

1.30

1.31

1.32

1.33

1.34

1.35

1.36

1.37

1.38

1.40

1.41

1.42

1.43

1.44

1.45

1.46

1.47

1.48

1.49

1.50

1.51

1.52

1.53

1.54

1.55

1.56

1.57

1.58

1.59

1.60

1.61

1.61RC

1.62

1.63

1.64

1.65

1.66

1.67

1.68

1.69

1.70

1.71

1.72

1.73

1.74

1.75

1.76

1.77

1.78

1.79

1.80

1.81

1.82

1.83

1.84

1.85

1.86

1.87

1.88

1.90

1.91

1.92

1.93

1.94

1.95

1.96

1.97

1.98

1.99

1;70

2.00

2.01

2.02

2.03

2.04

2.05

2.06

2.07

2.08

2.09

2.10

2.11

2.12

2.13

2.14

2.15

2.16

2.17

2.18

2.19

2.20

2.21

2.22

2.23

2.24

2.25

2.26

2.27

2.28

2.29

2.30

2.31

2.32

2.33

2.34

2.35

2.36

2.37

2.38

2.39

2.40

2.41

2.42

2.43

2.47

2.48

2.49

2.50

2.51

2.52

2.53

2.54

2.55

2.56

2.57

2.58

2.59

2.60

2.61

2.62

2.63

2.64

2.65

2.66

2.67

2.68

2.69

2.70

2.71

2.72

2.73

2.74

2.75

2.76

2.77

2.78

2.79

2.80

2.81

2.82

2.83

2.84

2.85

2.86

2.87

2.88

2.89

2.90

2.91

2.92

2.93

2.94

2.95

2.96

2.97

2.98

2.99

3.00

3.01

3.02

3.03

3.04

3.05

3.06

3.07

3.08

3.09

3.10

3.11

3.12

3.13

3.14

3.15

3.16

3.18

3.19

3.20

3.21

3.22

3.23

3.24

3.25

3.26

3.27

3.28

3.29

3.30

3.31

3.32

3.33

3.34

3.35

3.36

3.37

3.38

3.39

3.40

3.41

3.42

3.43

3.44

3.45

3.46

3.47

3.48

3.50

3.51

3.52

3.53

3.54

3.55

3.56

3.57

3.58

3.59

3.60

3.61

3.62

3.63

3.64

3.65

3.66

3.67

3.68

3.69

3.71

3.72

3.73

3.74

3.75

3.76

3.77

3.78

3.79

3.80

3.81

3.82

3.83

3.84

3.85

3.86

3.87

3.88

3.89

3.90

3.91

3.92

3.93

3.94

3.95

3.96

3.97

dev

helm-3.65.1

v0.69

v0.70beta

v3.33

Branches Tags

${ item.name }

Create tag ${ searchTerm }

Create branch ${ searchTerm }

from 'feature/mq-kafka-gateway-m1'

${ noResults }

seaweedfs/weed/mq/kafka/protocol

History

chrislu 5eec9484ca SeaweedMQHandler => brokers only, no agents		13 hours ago
..
api_versions_test.go	Fix API version tests after adding DescribeGroups and ListGroups APIs	4 days ago
compression_test.go	Phase 1 Part 1: Multi-batch fetch and GZIP compression	4 days ago
consumer_coordination.go	kafka: fix deadlock issues in static membership tests	4 days ago
consumer_coordination_test.go	fix-leavegroup-api-versions	4 days ago
consumer_group_metadata.go	fix: Handle null user data in JoinGroup protocol metadata parsing	4 days ago
consumer_group_metadata_test.go	Phase 4: Implement consumer group protocol metadata parsing	6 days ago
create_topics_test.go	Phase 2: Implement CreateTopics protocol compliance for v0/v1	6 days ago
describe_configs_test.go	fix: implement correct DescribeConfigs response format for all API versions	4 days ago
error_handling_test.go	kafka: fix flaky TestTimeoutDetection test	4 days ago
errors.go	kafka: fix HandleTimeoutError to properly handle context timeout errors	4 days ago
fetch.go	fmt	13 hours ago
fetch_multibatch.go	Phase 1 Part 1: Multi-batch fetch and GZIP compression	4 days ago
fetch_multibatch_test.go	Phase 1 Part 1: Multi-batch fetch and GZIP compression	4 days ago
fetch_test.go	fix tests	5 days ago
find_coordinator.go	debug	17 hours ago
find_coordinator_test.go	fix tests	3 days ago
flexible_versions.go	fix tests	6 days ago
flexible_versions_integration_test.go	Fix API version tests after adding DescribeGroups and ListGroups APIs	4 days ago
flexible_versions_test.go	Phase 7: Comprehensive error handling and edge cases	6 days ago
group_introspection.go	Implement static membership support (group.instance.id)	4 days ago
group_introspection_test.go	Phase 1 Part 2: Group introspection APIs	4 days ago
handler.go	SeaweedMQHandler => brokers only, no agents	13 hours ago
handler_test.go	fix tests	3 days ago
joingroup.go	join group api version	14 hours ago
logging.go	Phase 0 Part 2: API cleanup and structured logging	4 days ago
metrics.go	Phase 1 Complete: Client compatibility and metrics	4 days ago
metrics_test.go	Phase 1 Complete: Client compatibility and metrics	4 days ago
offset_handlers_test.go	fix in-memory variables	7 days ago
offset_management.go	debug	17 hours ago
offset_management_test.go	refactoring	6 days ago
produce.go	fmt	13 hours ago
produce_schema_test.go	fix tests	6 days ago
produce_schema_validation_test.go	fix: resolve Avro union re-encoding and schema validation test issues	4 days ago
produce_test.go	fix tests	6 days ago
record_batch_parser.go	persist kafka offset	1 week ago
record_batch_parser_test.go	persist kafka offset	1 week ago
schema_message_test.go	fmt	13 hours ago
schematized_fetch_integration_test.go	feat: integrate schematized fetch results into Fetch response	4 days ago
static_membership_test.go	Implement static membership support (group.instance.id)	4 days ago
test_handler.go	Add comprehensive test coverage for schema-based message handling	13 hours ago
test_utils.go	Add comprehensive test coverage for schema-based message handling	13 hours ago
version_matrix_test.go	fix tests	6 days ago
zigzag_varint_test.go	fix: correct ZigZag varint encoding for Kafka record format v2	4 days ago