Skip to content

Commit

Permalink
formatting
Browse files Browse the repository at this point in the history
  • Loading branch information
passuied committed Jan 9, 2024
1 parent 4e5596f commit dde6ec9
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions common/component/kafka/kafka.go
Original file line number Diff line number Diff line change
Expand Up @@ -47,13 +47,13 @@ type Kafka struct {
subscribeTopics TopicHandlerConfig
subscribeLock sync.Mutex

// schema registry settings
// schema registry settings
srClient srclient.ISchemaRegistryClient
schemaCachingEnabled bool
latestSchemaCache map[string]SchemaCacheEntry
latestSchemaCacheTTL time.Duration
latestSchemaCacheLock sync.RWMutex

// used for background logic that cannot use the context passed to the Init function
internalContext context.Context
internalContextCancel func()
Expand Down

0 comments on commit dde6ec9

Please sign in to comment.