Skip to content

Commit

Permalink
fix some
Browse files Browse the repository at this point in the history
  • Loading branch information
sharkpc138 committed Dec 19, 2024
1 parent aae1c86 commit 93a5e0a
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 4 deletions.
6 changes: 3 additions & 3 deletions pkg/lobster/sink/exporter/uploader/kafka.go
Original file line number Diff line number Diff line change
Expand Up @@ -41,7 +41,7 @@ type TokenProvider struct {
// In OAuth authentication, the required credentials
// for authentication vary across different systems
// Therefore, Lobster does not perform OAuth authentication
// directly but instead relies on the user to provide the access token
// directly but instead relies on the user to provide the access token.
func (t TokenProvider) Token() (*sarama.AccessToken, error) {
return &sarama.AccessToken{Token: t.token}, nil
}
Expand Down Expand Up @@ -165,8 +165,8 @@ func newConfig(kafka *v1.Kafka) (*sarama.Config, error) {

func newMessages(kafka *v1.Kafka, data []byte) []*sarama.ProducerMessage {
var (
start = 0
index = 0
start int
index int
b byte
messages = []*sarama.ProducerMessage{}
)
Expand Down
2 changes: 1 addition & 1 deletion pkg/lobster/util/scram_client.go
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@ var (
SHA512 scram.HashGeneratorFcn = sha512.New
)

// XDGSCRAMClient implements sarama.SCRAMClient
// XDGSCRAMClient implements sarama.SCRAMClient.
type XDGSCRAMClient struct {
*scram.Client
*scram.ClientConversation
Expand Down

0 comments on commit 93a5e0a

Please sign in to comment.