Signed-off-by: Noah Kreiger <[email protected]>

Signed-off-by: Noah Kreiger <[email protected]>

Signed-off-by: Noah Kreiger <[email protected]>

Signed-off-by: Noah Kreiger <[email protected]>

Signed-off-by: Noah Kreiger <[email protected]>

Signed-off-by: Pouya Vedadiyan <[email protected]>
Signed-off-by: Noah Kreiger <[email protected]>

Bumps [andstor/file-existence-action](https://github.com/andstor/file-existence-action) from 2 to 3.
- [Release notes](https://github.com/andstor/file-existence-action/releases)
- [Commits](andstor/file-existence-action@v2...v3)

---
updated-dependencies:
- dependency-name: andstor/file-existence-action
  dependency-type: direct:production
  update-type: version-update:semver-major
...

Signed-off-by: dependabot[bot] <[email protected]>
Signed-off-by: Noah Kreiger <[email protected]>

Bumps [golang.org/x/crypto](https://github.com/golang/crypto) from 0.14.0 to 0.17.0.
- [Commits](golang/crypto@v0.14.0...v0.17.0)

---
updated-dependencies:
- dependency-name: golang.org/x/crypto
  dependency-type: indirect
...

Signed-off-by: dependabot[bot] <[email protected]>
Signed-off-by: Noah Kreiger <[email protected]>

Bumps [golang.org/x/crypto](https://github.com/golang/crypto) from 0.14.0 to 0.17.0.
- [Commits](golang/crypto@v0.14.0...v0.17.0)

---
updated-dependencies:
- dependency-name: golang.org/x/crypto
  dependency-type: indirect
...

Signed-off-by: dependabot[bot] <[email protected]>
Signed-off-by: Noah Kreiger <[email protected]>

Bumps [golang.org/x/crypto](https://github.com/golang/crypto) from 0.14.0 to 0.17.0.
- [Commits](golang/crypto@v0.14.0...v0.17.0)

---
updated-dependencies:
- dependency-name: golang.org/x/crypto
  dependency-type: indirect
...

Signed-off-by: dependabot[bot] <[email protected]>
Signed-off-by: Noah Kreiger <[email protected]>

Bumps [golang.org/x/crypto](https://github.com/golang/crypto) from 0.14.0 to 0.17.0.
- [Commits](golang/crypto@v0.14.0...v0.17.0)

---
updated-dependencies:
- dependency-name: golang.org/x/crypto
  dependency-type: indirect
...

Signed-off-by: dependabot[bot] <[email protected]>
Signed-off-by: Noah Kreiger <[email protected]>

Bumps [golang.org/x/crypto](https://github.com/golang/crypto) from 0.14.0 to 0.17.0.
- [Commits](golang/crypto@v0.14.0...v0.17.0)

---
updated-dependencies:
- dependency-name: golang.org/x/crypto
  dependency-type: indirect
...

Signed-off-by: dependabot[bot] <[email protected]>
Signed-off-by: Noah Kreiger <[email protected]>

Bumps [golang.org/x/crypto](https://github.com/golang/crypto) from 0.14.0 to 0.17.0.
- [Commits](golang/crypto@v0.14.0...v0.17.0)

---
updated-dependencies:
- dependency-name: golang.org/x/crypto
  dependency-type: indirect
...

Signed-off-by: dependabot[bot] <[email protected]>
Signed-off-by: Noah Kreiger <[email protected]>

Bumps [golang.org/x/crypto](https://github.com/golang/crypto) from 0.14.0 to 0.17.0.
- [Commits](golang/crypto@v0.14.0...v0.17.0)

---
updated-dependencies:
- dependency-name: golang.org/x/crypto
  dependency-type: indirect
...

Signed-off-by: dependabot[bot] <[email protected]>
Signed-off-by: Noah Kreiger <[email protected]>

Bumps [golang.org/x/crypto](https://github.com/golang/crypto) from 0.14.0 to 0.17.0.
- [Commits](golang/crypto@v0.14.0...v0.17.0)

---
updated-dependencies:
- dependency-name: golang.org/x/crypto
  dependency-type: indirect
...

Signed-off-by: dependabot[bot] <[email protected]>
Signed-off-by: Noah Kreiger <[email protected]>

Bumps [golang.org/x/crypto](https://github.com/golang/crypto) from 0.14.0 to 0.17.0.
- [Commits](golang/crypto@v0.14.0...v0.17.0)

---
updated-dependencies:
- dependency-name: golang.org/x/crypto
  dependency-type: indirect
...

Signed-off-by: dependabot[bot] <[email protected]>
Signed-off-by: Noah Kreiger <[email protected]>

Bumps [golang.org/x/crypto](https://github.com/golang/crypto) from 0.14.0 to 0.17.0.
- [Commits](golang/crypto@v0.14.0...v0.17.0)

---
updated-dependencies:
- dependency-name: golang.org/x/crypto
  dependency-type: indirect
...

Signed-off-by: dependabot[bot] <[email protected]>
Signed-off-by: Noah Kreiger <[email protected]>

Bumps [golang.org/x/crypto](https://github.com/golang/crypto) from 0.14.0 to 0.17.0.
- [Commits](golang/crypto@v0.14.0...v0.17.0)

---
updated-dependencies:
- dependency-name: golang.org/x/crypto
  dependency-type: indirect
...

Signed-off-by: dependabot[bot] <[email protected]>
Signed-off-by: Noah Kreiger <[email protected]>

Bumps [golang.org/x/crypto](https://github.com/golang/crypto) from 0.14.0 to 0.17.0.
- [Commits](golang/crypto@v0.14.0...v0.17.0)

---
updated-dependencies:
- dependency-name: golang.org/x/crypto
  dependency-type: indirect
...

Signed-off-by: dependabot[bot] <[email protected]>
Signed-off-by: Noah Kreiger <[email protected]>

Signed-off-by: myan <[email protected]>
Signed-off-by: Noah Kreiger <[email protected]>

Signed-off-by: Calum Murray <[email protected]>
Signed-off-by: Noah Kreiger <[email protected]>

Signed-off-by: Calum Murray <[email protected]>
Signed-off-by: Noah Kreiger <[email protected]>

Signed-off-by: Calum Murray <[email protected]>
Signed-off-by: Noah Kreiger <[email protected]>

Signed-off-by: John A. Fossum <[email protected]>
Signed-off-by: Noah Kreiger <[email protected]>

Bumps [golangci/golangci-lint-action](https://github.com/golangci/golangci-lint-action) from 3 to 4.
- [Release notes](https://github.com/golangci/golangci-lint-action/releases)
- [Commits](golangci/golangci-lint-action@v3...v4)

---
updated-dependencies:
- dependency-name: golangci/golangci-lint-action
  dependency-type: direct:production
  update-type: version-update:semver-major
...

Signed-off-by: dependabot[bot] <[email protected]>
Signed-off-by: Noah Kreiger <[email protected]>

Bumps the bundler group with 1 update in the /docs directory: [nokogiri](https://github.com/sparklemotion/nokogiri).

Updates `nokogiri` from 1.14.3 to 1.16.2
- [Release notes](https://github.com/sparklemotion/nokogiri/releases)
- [Changelog](https://github.com/sparklemotion/nokogiri/blob/main/CHANGELOG.md)
- [Commits](sparklemotion/nokogiri@v1.14.3...v1.16.2)

---
updated-dependencies:
- dependency-name: nokogiri
  dependency-type: indirect
  dependency-group: bundler-security-group
...

Signed-off-by: dependabot[bot] <[email protected]>
Signed-off-by: Noah Kreiger <[email protected]>

Signed-off-by: Doug Davis <[email protected]>
Signed-off-by: Noah Kreiger <[email protected]>

Signed-off-by: Nghia Tran <[email protected]>
Signed-off-by: Noah Kreiger <[email protected]>

Signed-off-by: Noah Kreiger <[email protected]>

Bumps the go_modules group with 1 update in the /test/sql directory: [github.com/cloudevents/sdk-go/v2](https://github.com/cloudevents/sdk-go).

Updates `github.com/cloudevents/sdk-go/v2` from 2.14.0 to 2.15.2
- [Release notes](https://github.com/cloudevents/sdk-go/releases)
- [Commits](cloudevents/sdk-go@v2.14.0...v2.15.2)

---
updated-dependencies:
- dependency-name: github.com/cloudevents/sdk-go/v2
  dependency-type: direct:production
  dependency-group: go_modules-security-group
...

Signed-off-by: dependabot[bot] <[email protected]>
Signed-off-by: Noah Kreiger <[email protected]>

Bumps the go_modules group with 1 update in the /binding/format/protobuf/v2 directory: google.golang.org/protobuf.
Bumps the go_modules group with 1 update in the /protocol/pubsub/v2 directory: google.golang.org/protobuf.
Bumps the go_modules group with 1 update in the /samples/http directory: google.golang.org/protobuf.
Bumps the go_modules group with 1 update in the /samples/pubsub directory: google.golang.org/protobuf.

Updates `google.golang.org/protobuf` from 1.26.0 to 1.33.0

Updates `google.golang.org/protobuf` from 1.30.0 to 1.33.0

Updates `google.golang.org/protobuf` from 1.30.0 to 1.33.0

Updates `google.golang.org/protobuf` from 1.30.0 to 1.33.0

---
updated-dependencies:
- dependency-name: google.golang.org/protobuf
  dependency-type: direct:production
  dependency-group: go_modules-security-group
- dependency-name: google.golang.org/protobuf
  dependency-type: indirect
  dependency-group: go_modules-security-group
- dependency-name: google.golang.org/protobuf
  dependency-type: direct:production
  dependency-group: go_modules-security-group
- dependency-name: google.golang.org/protobuf
  dependency-type: indirect
  dependency-group: go_modules-security-group
...

Signed-off-by: dependabot[bot] <[email protected]>
Signed-off-by: Noah Kreiger <[email protected]>

Bumps the go_modules group with 1 update in the /samples/http directory: [github.com/gin-gonic/gin](https://github.com/gin-gonic/gin).

Updates `github.com/gin-gonic/gin` from 1.8.2 to 1.9.1
- [Release notes](https://github.com/gin-gonic/gin/releases)
- [Changelog](https://github.com/gin-gonic/gin/blob/master/CHANGELOG.md)
- [Commits](gin-gonic/gin@v1.8.2...v1.9.1)

---
updated-dependencies:
- dependency-name: github.com/gin-gonic/gin
  dependency-type: direct:production
  dependency-group: go_modules-security-group
...

Signed-off-by: dependabot[bot] <[email protected]>
Signed-off-by: Noah Kreiger <[email protected]>

Signed-off-by: myan <[email protected]>

add message implementation

Signed-off-by: myan <[email protected]>

add ut test

Signed-off-by: myan <[email protected]>

add integration test

Signed-off-by: myan <[email protected]>

add integration test and samples

Signed-off-by: Meng Yan <[email protected]>

offset

Signed-off-by: Meng Yan <[email protected]>

remove the ctx

Signed-off-by: myan <[email protected]>

 review

Signed-off-by: Meng Yan <[email protected]>

remove

Signed-off-by: Meng Yan <[email protected]>

init consumer and producer on 1 client

Signed-off-by: myan <[email protected]>

reply the reviews

Signed-off-by: myan <[email protected]>

fix the ci

Signed-off-by: myan <[email protected]>

ci fix

Signed-off-by: Meng Yan <[email protected]>

add confluent test in github action

Signed-off-by: Meng Yan <[email protected]>

add the mis-used test case

Signed-off-by: Meng Yan <[email protected]>

remove the invalidated bootstrapserver

Signed-off-by: Meng Yan <[email protected]>

log kafka error message

Signed-off-by: myan <[email protected]>

review

Signed-off-by: myan <[email protected]>

Update protocol/kafka_confluent/v2/option.go

Co-authored-by: Michael Gasch <[email protected]>
Signed-off-by: myan <[email protected]>

add the auto recover option

Signed-off-by: myan <[email protected]>

kafka error handler

Signed-off-by: myan <[email protected]>

remove the delievery chan

Signed-off-by: myan <[email protected]>

Update protocol/kafka_confluent/v2/protocol.go

Co-authored-by: Michael Gasch <[email protected]>

Update protocol/kafka_confluent/v2/protocol.go

Co-authored-by: Michael Gasch <[email protected]>

Update protocol/kafka_confluent/v2/option.go

Co-authored-by: Michael Gasch <[email protected]>

Update protocol/kafka_confluent/v2/protocol.go

Co-authored-by: Michael Gasch <[email protected]>

reply review

Signed-off-by: myan <[email protected]>

modify the git action

Signed-off-by: Meng Yan <[email protected]>

reply review

Signed-off-by: Meng Yan <[email protected]>

reply review

Signed-off-by: Meng Yan <[email protected]>

handle race condition between sender and closer

Signed-off-by: Meng Yan <[email protected]>

reply review

Signed-off-by: Meng Yan <[email protected]>

reply review1

Signed-off-by: Meng Yan <[email protected]>

add defer close

Signed-off-by: Meng Yan <[email protected]>

add comment

Signed-off-by: Meng Yan <[email protected]>
Signed-off-by: Noah Kreiger <[email protected]>

Signed-off-by: Meng Yan <[email protected]>

reply review

Signed-off-by: Meng Yan <[email protected]>

Update protocol/kafka_confluent/v2/protocol.go

Co-authored-by: Michael Gasch <[email protected]>
Signed-off-by: Meng Yan <[email protected]>
Signed-off-by: Noah Kreiger <[email protected]>

This enables the encoding/decoding of custom content types which
use the `+json` or `+xml` suffix to indicate that their encoding
is JSON or XML respectively. Users can also add their own suffixes
to the registry in a similar fashion to how `datacodec.AddDecoder()`
and `dataodec.AddEncoder()` work, but via the `AddStructuredSuffixDecoder`
and `AddStructuredSuffixEncoder` functions.

Signed-off-by: dan-j <[email protected]>
Signed-off-by: Noah Kreiger <[email protected]>

Bumps the go_modules group with 1 update in the /observability/opencensus/v2 directory: [golang.org/x/net](https://github.com/golang/net).
Bumps the go_modules group with 1 update in the /protocol/kafka_sarama/v2 directory: [golang.org/x/net](https://github.com/golang/net).
Bumps the go_modules group with 1 update in the /protocol/pubsub/v2 directory: [golang.org/x/net](https://github.com/golang/net).
Bumps the go_modules group with 1 update in the /samples/http directory: [golang.org/x/net](https://github.com/golang/net).
Bumps the go_modules group with 1 update in the /samples/kafka directory: [golang.org/x/net](https://github.com/golang/net).
Bumps the go_modules group with 1 update in the /samples/pubsub directory: [golang.org/x/net](https://github.com/golang/net).
Bumps the go_modules group with 1 update in the /test/benchmark directory: [golang.org/x/net](https://github.com/golang/net).
Bumps the go_modules group with 1 update in the /test/conformance directory: [golang.org/x/net](https://github.com/golang/net).
Bumps the go_modules group with 1 update in the /test/integration directory: [golang.org/x/net](https://github.com/golang/net).

Updates `golang.org/x/net` from 0.17.0 to 0.23.0
- [Commits](golang/net@v0.17.0...v0.23.0)

Updates `golang.org/x/net` from 0.17.0 to 0.23.0
- [Commits](golang/net@v0.17.0...v0.23.0)

Updates `golang.org/x/net` from 0.17.0 to 0.23.0
- [Commits](golang/net@v0.17.0...v0.23.0)

Updates `golang.org/x/net` from 0.17.0 to 0.23.0
- [Commits](golang/net@v0.17.0...v0.23.0)

Updates `golang.org/x/net` from 0.17.0 to 0.23.0
- [Commits](golang/net@v0.17.0...v0.23.0)

Updates `golang.org/x/net` from 0.17.0 to 0.23.0
- [Commits](golang/net@v0.17.0...v0.23.0)

Updates `golang.org/x/net` from 0.17.0 to 0.23.0
- [Commits](golang/net@v0.17.0...v0.23.0)

Updates `golang.org/x/net` from 0.17.0 to 0.23.0
- [Commits](golang/net@v0.17.0...v0.23.0)

Updates `golang.org/x/net` from 0.17.0 to 0.23.0
- [Commits](golang/net@v0.17.0...v0.23.0)

---
updated-dependencies:
- dependency-name: golang.org/x/net
  dependency-type: indirect
  dependency-group: go_modules
- dependency-name: golang.org/x/net
  dependency-type: indirect
  dependency-group: go_modules
- dependency-name: golang.org/x/net
  dependency-type: indirect
  dependency-group: go_modules
- dependency-name: golang.org/x/net
  dependency-type: indirect
  dependency-group: go_modules
- dependency-name: golang.org/x/net
  dependency-type: indirect
  dependency-group: go_modules
- dependency-name: golang.org/x/net
  dependency-type: indirect
  dependency-group: go_modules
- dependency-name: golang.org/x/net
  dependency-type: indirect
  dependency-group: go_modules
- dependency-name: golang.org/x/net
  dependency-type: indirect
  dependency-group: go_modules
- dependency-name: golang.org/x/net
  dependency-type: indirect
  dependency-group: go_modules
...

Signed-off-by: dependabot[bot] <[email protected]>
Signed-off-by: Noah Kreiger <[email protected]>

Signed-off-by: Noah Kreiger <[email protected]>

Signed-off-by: Noah Kreiger <[email protected]>

Signed-off-by: Noah Kreiger <[email protected]>

Signed-off-by: Noah Kreiger <[email protected]>

Co-authored-by: Michael Gasch <[email protected]>
Signed-off-by: Noah Kreiger <[email protected]>

Signed-off-by: Noah Kreiger <[email protected]>

Ref: cloudevents/spec#1275
Signed-off-by: Michael Gasch <[email protected]>
Signed-off-by: Noah Kreiger <[email protected]>

Closes: cloudevents#1037
Signed-off-by: Michael Gasch <[email protected]>
Signed-off-by: Noah Kreiger <[email protected]>

Co-authored-by: Michael Gasch <[email protected]>
Signed-off-by: Noah Kreiger <[email protected]>

Co-authored-by: Michael Gasch <[email protected]>
Signed-off-by: Noah Kreiger <[email protected]>

Signed-off-by: Noah Kreiger <[email protected]>

Signed-off-by: Noah Kreiger <[email protected]>

Signed-off-by: Noah Kreiger <[email protected]>

Signed-off-by: Noah Kreiger <[email protected]>