github-vet / github-vet/rangeloop-pointer-findings
knative-sandbox/eventing-kafka: pkg/channel/distributed/common/kafka/admin/eventhubcache/cache.go; 34 LoC
- Dominant language
- No language data
- Stars
- 0
- Forks
- 0
- PR merge metrics
- PR metrics pending
Description
Found a possible issue in [knative-sandbox/eventing-kafka](https://www.github.com/knative-sandbox/eventing-kafka) at [pkg/channel/distributed/common/kafka/admin/eventhubcache/cache.go](https://github.com/knative-sandbox/eventing-kafka/blob/3d1488fcf8244a6299956994fc08fc3c53354ffb/pkg/channel/distributed/common/kafka/admin/eventhubcache/cache.go#L89-L122)
Below is the message reported by the analyzer for this snippet of code. Beware that the analyzer only reports the first
issue it finds, so please do not limit your consideration to the contents of the below message.
> function call which takes a reference to kafkaSecret at line 92 may start a goroutine
[Click here to see the code in its original context.](https://github.com/knative-sandbox/eventing-kafka/blob/3d1488fcf8244a6299956994fc08fc3c53354ffb/pkg/channel/distributed/common/kafka/admin/eventhubcache/cache.go#L89-L122)
Click here to show the 34 line(s) of Go which triggered the analyzer.
```go
for _, kafkaSecret := range kafkaSecrets.Items {
// Validate Secret Data
if !c.validateKafkaSecret(&kafkaSecret) {
err = errors.New("invalid Kafka Secret found")
c.logger.Error("Found Invalid Kafka Secret", zap.Any("Kafka Secret", kafkaSecret), zap.Error(err))
return err
}
// Create A New Namespace From The Secret
namespace, err := NewNamespaceFromKafkaSecret(c.logger, &kafkaSecret)
if err != nil {
c.logger.Error("Failed To Get Namespace From Kafka Secret", zap.Any("Kafka Secret", kafkaSecret), zap.Error(err))
return err
}
// Add The Namespace To The Namespace Map
c.namespaceMap[namespace.Name] = namespace
// List The EventHubs For The Namespace
eventHubs, err := namespace.HubManager.List(ctx)
if err != nil {
c.logger.Error("Failed To List EventHubs In Namespace", zap.String("Namespace", namespace.Name), zap.Error(err))
return err
}
// Loop Over The EventHubs For The Namespace
for _, eventHub := range eventHubs {
// Add The EventHub To The Namespace & Increment The Namespace EventHub Count
c.eventhubMap[eventHub.Name] = namespace
namespace.Count = namespace.Count + 1
}
}
```
Click here to show extra information the analyzer produced.
```
The following paths through the callgraph could lead to a goroutine:
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Close, 0) -> (Broadcast, 0) -> (conversionHandler, 3) -> (Convert, 2) -> (DispatchMessageWithRetries, 7) -> (executeRequest, 5) -> (PassThroughHeaders, 1) -> (CheckRetry, 1) -> (truncatingFormat, 1) -> (detectRaces, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Get, 0) -> (MatchString, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Write, 1) -> (printWithFileLine, 6) -> (output, 6)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Sign, 0) -> (UnscaledBig, 0) -> (Err, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Error, 0) -> (normalized, 0) -> (mergePaths, 2) -> (containsString, 2) -> (Retrieve, 0) -> (profile, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (String, 0) -> (URL, 1) -> (parseText, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (swapBufs, 1) -> (Add, 1) -> (add, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Decode, 1) -> (ParseUint, 3) -> (hasRecentError, 2) -> (newCountValue, 2) -> (newQueue, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (open, 0) -> (newObject, 1) -> (toObjectACLRules, 1) -> (toObjectACLRule, 1) -> (addEvent, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (nextBlock, 1) -> (println, 1) -> (setPrev, 3) -> (compareSwap, 3) -> (StartConsumerGroup, 4)
(validateKafkaSecret, 1) -> (String, 2) -> (Equal, 2) -> (cachingEqual, 3) -> (Range, 1) -> (extensionMap, 1) -> (handleResponse, 1) -> (handleSuccess, 2) -> (NewNamedDelayingQueue, 1) -> (NewDelayingQueueWithCustomClock, 2)
(validateKafkaSecret, 1) -> (String, 2) -> (Equal, 2) -> (cachingEqual, 3) -> (Range, 1) -> (extensionMap, 1) -> (handleResponse, 1) -> (handleSuccess, 2) -> (ConfigureTransports, 1) -> (configureTransports, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (String, 0) -> (URL, 1) -> (parseText, 1) -> (next, 0) -> (ConfigureTransport, 1) -> (ConfigureTransports, 1) -> (configureTransports, 1) -> (addConnIfNeeded, 3)
(validateKafkaSecret, 1) -> (String, 2) -> (Reset, 0) -> (make, 2) -> (init, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (String, 0) -> (URL, 1) -> (parseText, 1) -> (next, 0) -> (RunContext, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (MarshalText, 0) -> (Level, 0) -> (int8, 1) -> (loggerOptionFunc, 1) -> (asyncFlush, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (ValueOf, 1) -> (valueOfIface, 1) -> (valueOfBytes, 1) -> (newValidationInfo, 2) -> (Cleanup, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (rotateFile, 1) -> (Version, 0) -> (Version, 1) -> (Flag, 2) -> (DispatchMessageWithRetries, 7) -> (executeRequest, 5) -> (PassThroughHeaders, 1) -> (CheckRetry, 1) -> (truncatingFormat, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (open, 0) -> (newObject, 1) -> (toObjectACLRules, 1) -> (toObjectACLRule, 1) -> (StartConsumerGroup, 4) -> (Consume, 3) -> (release, 1) -> (topicToPartitionNumbers, 1) -> (Partitions, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Start, 0) -> (start, 0) -> (UpdateState, 1) -> (updateResolverState, 2) -> (maybeApplyDefaultServiceConfig, 1) -> (applyServiceConfigAndBalancer, 3) -> (newCCBalancerWrapper, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Write, 1) -> (printWithFileLine, 6) -> (output, 6) -> (timeoutFlush, 1) -> (handleSuccess, 2) -> (dropPartition, 2) -> (getBrokerProducer, 1) -> (newBrokerProducer, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Decode, 1) -> (ParseUint, 3) -> (hasRecentError, 2) -> (newCountValue, 2) -> (handleSuccess, 2) -> (dropPartition, 2) -> (getBrokerProducer, 1) -> (newBrokerProducer, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Sign, 0) -> (UnscaledBig, 0) -> (Err, 0) -> (Proto, 0) -> (runPiped, 4) -> (runWithFriendlyError, 3) -> (run, 3) -> (runCmdContext, 2) -> (newClientConn, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (rotateFile, 1) -> (Version, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (compressBlock, 1) -> (, 0) -> (NewStream, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Sign, 0) -> (UnscaledBig, 0) -> (Err, 0) -> (Proto, 0) -> (Get, 2) -> (NewSharedIndexInformer, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (End, 0) -> (ExportSpan, 1) -> (Infof, 5) -> (canonicalCodeString, 1) -> (combineBodyMedia, 5) -> (newMultipartReader, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Start, 0) -> (start, 0) -> (UpdateState, 1) -> (updateResolverState, 2) -> (sendAndReceiveKerberos, 0) -> (Authorize, 1) -> (readPackage, 1) -> (NewInitiatorWrapToken, 2) -> (SetCheckSum, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (String, 0) -> (URL, 1)
(validateKafkaSecret, 1) -> (String, 2) -> (AsStringSlice, 1) -> (Index, 1) -> (lazyInit, 0) -> (lazyInitSlow, 0) -> (newValidationInfo, 2) -> (IsWeak, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (MarshalText, 0) -> (Level, 0) -> (int8, 1) -> (loggerOptionFunc, 1) -> (ConfigureTransport, 1) -> (ConfigureTransports, 1) -> (configureTransports, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (Write, 1) -> (printWithFileLine, 6) -> (output, 6) -> (timeoutFlush, 1) -> (RemoteCredProvider, 2) -> (ec2RoleProvider, 2) -> (EndpointFor, 2) -> (Of, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Do, 1) -> (transformResponse, 2) -> (isTextResponse, 1) -> (NewGenericServerResponse, 7) -> (combineBodyMedia, 5) -> (newMultipartReader, 2)
(validateKafkaSecret, 1) -> (String, 2) -> (Equal, 2) -> (cachingEqual, 3) -> (Get, 1) -> (GetUsing, 2) -> (allocValueUnstructured, 0) -> (allocate, 0) -> (ConfigureTransports, 1) -> (configureTransports, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (String, 0) -> (URL, 1) -> (parseText, 1) -> (next, 0) -> (handleRawConn, 1) -> (removeConn, 1) -> (methodFamily, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Close, 0) -> (Broadcast, 0) -> (conversionHandler, 3) -> (Convert, 2) -> (RoundTrip, 1) -> (after, 3) -> (shouldEscape, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (cancel, 0) -> (Stop, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (compressBlock, 1) -> (, 0) -> (NewStream, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Get, 0) -> (MatchString, 1) -> (ReadFile, 1) -> (ReadObject, 3) -> (startFrameWrite, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (stringOff, 1) -> (WriteString, 1) -> (Get, 0) -> (MatchString, 1) -> (ReadFile, 1) -> (ReadObject, 3) -> (executeCredentialProcess, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (IsZero, 0) -> (Sign, 0) -> (IsNegative, 0) -> (Shutdown, 1) -> (handleRawConn, 1) -> (removeConn, 1) -> (methodFamily, 1) -> (processStreamingRPC, 5)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (IsZero, 0) -> (Sign, 0) -> (IsNegative, 0) -> (Shutdown, 1) -> (RunRaw, 2) -> (runPiped, 4) -> (runWithFriendlyError, 3) -> (run, 3) -> (runCmdContext, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Bytes, 0) -> (BytesVar, 1) -> (newBytesValue, 1) -> (remaining, 0) -> (consume, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (FormatDiff, 2) -> (formatDiffList, 3) -> (CanInterface, 0) -> (fromString, 1) -> (getContext, 0) -> (NewContext, 0) -> (SetupSignalHandler, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Validate, 0) -> (New, 1) -> (HTTPWrappersForConfig, 2) -> (NewImpersonatingRoundTripper, 2) -> (ConfigureTransport, 1) -> (ConfigureTransports, 1) -> (configureTransports, 1) -> (addConnIfNeeded, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Sign, 0) -> (UnscaledBig, 0) -> (Err, 0) -> (Proto, 0) -> (Send, 2) -> (reportCount, 3) -> (ReportCRStatusEvent, 2) -> (createEvent, 2) -> (getRecorder, 4) -> (NewRecorder, 2) -> (recordToSink, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (Close, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Write, 1) -> (printWithFileLine, 6)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (cancel, 0) -> (Stop, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Append, 2) -> (FullName, 0) -> (formatDescOpt, 3) -> (ContainingMessage, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (FormatDiff, 2) -> (formatDiffList, 3) -> (CanInterface, 0) -> (fromString, 1) -> (StartConsumerGroup, 4) -> (Consume, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (MarshalText, 0) -> (Level, 0) -> (int8, 1) -> (loggerOptionFunc, 1) -> (handleSuccess, 2) -> (dropPartition, 2) -> (getBrokerProducer, 1) -> (newBrokerProducer, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Validate, 0) -> (New, 1) -> (HTTPWrappersForConfig, 2) -> (NewImpersonatingRoundTripper, 2) -> (handleSuccess, 2) -> (dropPartition, 2) -> (getBrokerProducer, 1) -> (newBrokerProducer, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (Do, 1) -> (transformResponse, 2) -> (isTextResponse, 1) -> (NewGenericServerResponse, 7) -> (RoundTrip, 1) -> (after, 3) -> (shouldEscape, 1) -> (legalHeaderByte, 1) -> (GroupVersions, 1)
(validateKafkaSecret, 1) -> (String, 2) -> (Reset, 0) -> (make, 2) -> (, 0) -> (NewStream, 3) -> (Store, 1) -> (packError, 1) -> (Equal, 3) -> (Equal, 4) -> (formatUnequalValues, 2) -> (truncatingFormat, 1) -> (SplitAfter, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Decode, 1) -> (ParseUint, 3) -> (hasRecentError, 2) -> (newCountValue, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (open, 0) -> (newObject, 1) -> (toObjectACLRules, 1) -> (toObjectACLRule, 1) -> (Cleanup, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (Write, 1) -> (printWithFileLine, 6) -> (output, 6) -> (timeoutFlush, 1) -> (getLoggingConfig, 1) -> (ConfigToJSON, 1) -> (levelFromString, 1) -> (lex, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (FullPath, 0) -> (Free, 0) -> (unref, 0) -> (freeTrace, 1) -> (ConfigureTransport, 1) -> (ConfigureTransports, 1) -> (configureTransports, 1) -> (addConnIfNeeded, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (Write, 1) -> (printWithFileLine, 6) -> (output, 6) -> (timeoutFlush, 1) -> (newQueue, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Get, 0) -> (MatchString, 1) -> (ReadFile, 1) -> (ReadObject, 3) -> (newQueue, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Do, 1) -> (transformResponse, 2) -> (isTextResponse, 1) -> (NewGenericServerResponse, 7) -> (newAsyncProducer, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (nextBlock, 1) -> (println, 1) -> (setPrev, 3) -> (compareSwap, 3) -> (newAsyncProducer, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (compressBlock, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Sign, 0) -> (UnscaledBig, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Start, 0) -> (start, 0) -> (UpdateState, 1) -> (updateResolverState, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (New, 1) -> (HTTPWrappersForConfig, 2) -> (NewImpersonatingRoundTripper, 2) -> (Token, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (nextBlock, 1) -> (println, 1) -> (setPrev, 3) -> (compareSwap, 3) -> (DispatchMessageWithRetries, 7) -> (executeRequest, 5) -> (PassThroughHeaders, 1) -> (CheckRetry, 1) -> (truncatingFormat, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (stringOff, 1) -> (WriteString, 1) -> (prepareNext, 1) -> (, 0) -> (NewStream, 3) -> (DurationP, 4) -> (sendAndReceiveKerberos, 0) -> (Authorize, 1) -> (readPackage, 1) -> (NewInitiatorWrapToken, 2) -> (SetCheckSum, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (Do, 1) -> (transformResponse, 2) -> (isTextResponse, 1) -> (NewGenericServerResponse, 7) -> (newMultipartReader, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (FormatDiff, 2) -> (formatDiffList, 3) -> (CanInterface, 0) -> (fromString, 1) -> (newConsumerGroupClaim, 4) -> (handleError, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (New, 1) -> (HTTPWrappersForConfig, 2) -> (NewImpersonatingRoundTripper, 2) -> (Token, 0) -> (NewNamedDelayingQueue, 1) -> (NewDelayingQueueWithCustomClock, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Has, 1) -> (findJsonNameField, 1) -> (CanOmit, 1) -> (isZero, 1) -> (combineBodyMedia, 5) -> (newMultipartReader, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (open, 0) -> (newObject, 1) -> (toObjectACLRules, 1) -> (toObjectACLRule, 1) -> (NewEventListener, 3)
(validateKafkaSecret, 1) -> (String, 2) -> (Reset, 0) -> (make, 2) -> (Add, 1) -> (insert, 1) -> (evict, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Write, 1) -> (printWithFileLine, 6) -> (output, 6) -> (timeoutFlush, 1) -> (newQueue, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Value, 0) -> (ScaledValue, 1) -> (infScale, 0) -> (DivMod, 3) -> (Cleanup, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Start, 0) -> (start, 0) -> (UpdateState, 1) -> (updateResolverState, 2) -> (StartConsumerGroup, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Sign, 0) -> (UnscaledBig, 0) -> (Err, 0) -> (Proto, 0) -> (processNextWorkItem, 0) -> (handleErr, 2) -> (ShuttingDown, 0) -> (AdmissionregistrationV1, 0) -> (newValidatingWebhookConfigurations, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Do, 1) -> (transformResponse, 2) -> (isTextResponse, 1) -> (NewGenericServerResponse, 7) -> (sendAndReceiveKerberos, 0) -> (Authorize, 1) -> (readPackage, 1) -> (NewInitiatorWrapToken, 2) -> (SetCheckSum, 2)
(validateKafkaSecret, 1) -> (String, 2) -> (Reset, 0) -> (make, 2) -> (Stop, 0) -> (Done, 0) -> (closeDoneLocked, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (MarshalText, 0) -> (Level, 0) -> (int8, 1) -> (loggerOptionFunc, 1) -> (connect, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Start, 0) -> (start, 0) -> (UpdateState, 1) -> (updateResolverState, 2) -> (StartConsumerGroup, 4) -> (Consume, 3)
(validateKafkaSecret, 1) -> (String, 2) -> (Reset, 0) -> (make, 2) -> (, 0) -> (NewStream, 3) -> (Store, 1) -> (packError, 1) -> (NewConfigFromMap, 1) -> (levelFromString, 1) -> (lex, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (Close, 0) -> (Broadcast, 0) -> (conversionHandler, 3) -> (Convert, 2) -> (StartConsumerGroup, 4) -> (Consume, 3) -> (release, 1) -> (topicToPartitionNumbers, 1) -> (Partitions, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (nextBlock, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Write, 2) -> (WriteFile, 4) -> (RaceReadRange, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Decode, 1) -> (ParseUint, 3) -> (hasRecentError, 2) -> (newCountValue, 2) -> (NewNamedRateLimitingQueue, 2) -> (NewNamedDelayingQueue, 1) -> (NewDelayingQueueWithCustomClock, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (Get, 0) -> (MatchString, 1) -> (ReadFile, 1) -> (ReadObject, 3) -> (localHTTPCredProvider, 3) -> (Log, 3) -> (Of, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (FormatDiff, 2) -> (formatDiffList, 3) -> (CanInterface, 0)
(validateKafkaSecret, 1) -> (String, 2) -> (Reset, 0) -> (make, 2) -> (init, 0) -> (UTC, 0) -> (setCurMetricsConfig, 1) -> (setCurMetricsConfigUnlocked, 1) -> (processNextWorkItem, 0) -> (handleErr, 2) -> (ShuttingDown, 0) -> (AdmissionregistrationV1, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Start, 0) -> (start, 0) -> (UpdateState, 1) -> (updateResolverState, 2) -> (DispatchMessageWithRetries, 7) -> (executeRequest, 5) -> (PassThroughHeaders, 1) -> (CheckRetry, 1) -> (truncatingFormat, 1) -> (detectRaces, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Parse, 1) -> (parseText, 1) -> (next, 0) -> (fill, 1) -> (startFrameWrite, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (IsZero, 0) -> (Sign, 0) -> (IsNegative, 0) -> (Shutdown, 1) -> (StartSteps, 2) -> (ExecutePace, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (prepareNext, 1) -> (append, 3) -> (BoolVar, 1) -> (typeName, 0) -> (getLoggingConfig, 1) -> (ConfigToJSON, 1) -> (levelFromString, 1) -> (lex, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Start, 0) -> (start, 0) -> (UpdateState, 1) -> (updateResolverState, 2) -> (createTransport, 3) -> (NewClientTransport, 7) -> (newHTTP2Client, 7) -> (newLoopyWriter, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Close, 0) -> (Broadcast, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (nextBlock, 1) -> (println, 1) -> (setPrev, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (Get, 0) -> (MatchString, 1) -> (ReadFile, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (Reset, 1) -> (resetMessage, 1) -> (SetUnknown, 1) -> (setUnknown, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (open, 0) -> (newObject, 1) -> (toObjectACLRules, 1) -> (toObjectACLRule, 1) -> (DispatchMessageWithRetries, 7) -> (executeRequest, 5) -> (PassThroughHeaders, 1) -> (CheckRetry, 1) -> (truncatingFormat, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (compressBlock, 1) -> (, 0) -> (NewStream, 3) -> (DurationP, 4) -> (DispatchMessageWithRetries, 7) -> (executeRequest, 5) -> (PassThroughHeaders, 1) -> (CheckRetry, 1) -> (truncatingFormat, 1) -> (detectRaces, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (prepareNext, 1) -> (append, 3) -> (BoolVar, 1) -> (typeName, 0) -> (List, 1) -> (ListFunc, 1) -> (WithPath, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (String, 0) -> (URL, 1) -> (parseText, 1) -> (next, 0) -> (updateResolverState, 2) -> (updateClientConnState, 1) -> (UpdateClientConnState, 1) -> (UpdateAddresses, 1) -> (newAddrConn, 2) -> (RegisterSubChannel, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Sign, 0) -> (UnscaledBig, 0) -> (Err, 0) -> (Proto, 0) -> (SendAlert, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (compressBlock, 1) -> (, 0) -> (NewStream, 3) -> (DurationP, 4) -> (StartConsumerGroup, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (Do, 1) -> (transformResponse, 2) -> (isTextResponse, 1) -> (NewGenericServerResponse, 7) -> (Build, 3)
(validateKafkaSecret, 1) -> (String, 2) -> (Reset, 0) -> (make, 2) -> (init, 0) -> (UTC, 0) -> (setCurMetricsConfig, 1) -> (setCurMetricsConfigUnlocked, 1) -> (applyServiceConfigAndBalancer, 3) -> (newCCBalancerWrapper, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (prepareNext, 1) -> (append, 3) -> (BoolVar, 1) -> (typeName, 0) -> (NewEventListener, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Sign, 0) -> (UnscaledBig, 0) -> (Err, 0) -> (Proto, 0) -> (StartSteps, 2) -> (ExecutePace, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (FullPath, 0) -> (Free, 0) -> (unref, 0) -> (freeTrace, 1) -> (ConfigureTransport, 1) -> (ConfigureTransports, 1) -> (configureTransports, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (prepareNext, 1) -> (append, 3) -> (BoolVar, 1) -> (typeName, 0) -> (StartConsumerGroup, 4) -> (Consume, 3) -> (release, 1) -> (topicToPartitionNumbers, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Value, 0) -> (ScaledValue, 1) -> (infScale, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (End, 0) -> (ExportSpan, 1) -> (Infof, 5)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (printWithFileLine, 5) -> (output, 5) -> (putBuffer, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (String, 0) -> (URL, 1) -> (parseText, 1) -> (next, 0) -> (handleResponse, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (nextBlock, 1) -> (println, 1) -> (setPrev, 3) -> (compareSwap, 3) -> (StartConsumerGroup, 4) -> (Consume, 3) -> (release, 1) -> (topicToPartitionNumbers, 1) -> (Partitions, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Validate, 0) -> (New, 1) -> (HTTPWrappersForConfig, 2) -> (NewImpersonatingRoundTripper, 2) -> (ConfigureTransport, 1) -> (ConfigureTransports, 1) -> (configureTransports, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Len, 0) -> (Get, 0) -> (readFileFromKoData, 1) -> (hasInformer, 0) -> (ConfigureTransport, 1) -> (ConfigureTransports, 1) -> (configureTransports, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (FormatDiff, 2) -> (formatDiffList, 3) -> (CanInterface, 0) -> (fromString, 1) -> (RoundTrip, 1) -> (after, 3) -> (shouldEscape, 1) -> (legalHeaderByte, 1) -> (RelativizePathWithNoBacksteps, 2) -> (MakeRelative, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Has, 1) -> (findJsonNameField, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (compressBlock, 1) -> (, 0) -> (NewStream, 3) -> (DurationP, 4) -> (newAsyncProducer, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (MarshalText, 0) -> (Level, 0) -> (int8, 1) -> (loggerOptionFunc, 1) -> (Get, 2) -> (NewSharedIndexInformer, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (MarshalText, 0) -> (Level, 0) -> (int8, 1) -> (loggerOptionFunc, 1) -> (NewNamedRateLimitingQueue, 2) -> (NewNamedDelayingQueue, 1) -> (NewDelayingQueueWithCustomClock, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Error, 0) -> (normalized, 0) -> (mergePaths, 2) -> (containsString, 2) -> (handleSuccess, 2) -> (dropPartition, 2) -> (getBrokerProducer, 1) -> (newBrokerProducer, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (stringOff, 1) -> (WriteString, 1) -> (prepareNext, 1) -> (, 0) -> (NewStream, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Get, 0) -> (MatchString, 1) -> (ReadFile, 1) -> (ReadObject, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Sign, 0) -> (UnscaledBig, 0) -> (Err, 0) -> (Proto, 0) -> (OpenInbound, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (Get, 0) -> (MatchString, 1) -> (ReadFile, 1) -> (ReadObject, 3) -> (executeCredentialProcess, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (stringOff, 1) -> (WriteString, 1) -> (Get, 0) -> (MatchString, 1) -> (ReadFile, 1) -> (ReadObject, 3) -> (ConfigureTransports, 1) -> (configureTransports, 1) -> (addConnIfNeeded, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Parse, 1) -> (parseText, 1) -> (next, 0) -> (fill, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Start, 0) -> (start, 0) -> (UpdateState, 1) -> (updateResolverState, 2) -> (poller, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (open, 0) -> (newObject, 1) -> (toObjectACLRules, 1) -> (toObjectACLRule, 1) -> (StartConsumerGroup, 4) -> (Consume, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (compressBlock, 1) -> (, 0) -> (NewStream, 3) -> (DurationP, 4) -> (RoundTrip, 1) -> (after, 3) -> (shouldEscape, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Sign, 0) -> (UnscaledBig, 0) -> (Err, 0) -> (Proto, 0) -> (getContext, 0) -> (NewContext, 0) -> (SetupSignalHandler, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (Get, 0) -> (MatchString, 1) -> (ReadFile, 1) -> (ReadObject, 3) -> (ConfigureTransports, 1) -> (configureTransports, 1) -> (addConnIfNeeded, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (open, 0) -> (newObject, 1) -> (toObjectACLRules, 1) -> (toObjectACLRule, 1) -> (StartConsumerGroup, 4) -> (Consume, 3) -> (release, 1) -> (topicToPartitionNumbers, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (prepareNext, 1) -> (append, 3) -> (BoolVar, 1) -> (typeName, 0) -> (DispatchMessageWithRetries, 7) -> (executeRequest, 5) -> (PassThroughHeaders, 1) -> (CheckRetry, 1) -> (truncatingFormat, 1) -> (SplitAfter, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Len, 0) -> (Get, 0) -> (readFileFromKoData, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (rotateFile, 1) -> (Version, 0) -> (Version, 1) -> (Flag, 2) -> (NewEventListener, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (IsZero, 0) -> (Sign, 0) -> (IsNegative, 0) -> (Shutdown, 1) -> (PollUntil, 3) -> (WaitFor, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Start, 0) -> (start, 0) -> (UpdateState, 1) -> (updateResolverState, 2) -> (updateClientConnState, 1) -> (UpdateClientConnState, 1)
(validateKafkaSecret, 1) -> (String, 2) -> (Reset, 0) -> (make, 2) -> (init, 0) -> (UTC, 0) -> (setCurMetricsConfig, 1) -> (setCurMetricsConfigUnlocked, 1) -> (runPiped, 4) -> (runWithFriendlyError, 3) -> (run, 3) -> (runCmdContext, 2) -> (newClientConn, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Write, 1) -> (printWithFileLine, 6) -> (output, 6) -> (timeoutFlush, 1) -> (DispatchMessageWithRetries, 7) -> (executeRequest, 5) -> (PassThroughHeaders, 1) -> (CheckRetry, 1) -> (truncatingFormat, 1) -> (SplitAfter, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (withDeadline, 2) -> (WithDeadline, 2) -> (AfterFunc, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Write, 1) -> (printWithFileLine, 6) -> (output, 6) -> (timeoutFlush, 1) -> (Retrieve, 0) -> (profile, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Start, 0) -> (start, 0) -> (UpdateState, 1) -> (updateResolverState, 2) -> (StartConsumerGroup, 4) -> (Consume, 3) -> (release, 1) -> (topicToPartitionNumbers, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (prepareNext, 1) -> (append, 3) -> (BoolVar, 1) -> (typeName, 0) -> (DispatchMessageWithRetries, 7) -> (executeRequest, 5) -> (PassThroughHeaders, 1) -> (CheckRetry, 1) -> (truncatingFormat, 1)
(validateKafkaSecret, 1) -> (String, 2) -> (Reset, 0) -> (make, 2) -> (Reset, 1) -> (resetMessage, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (printWithFileLine, 5) -> (output, 5) -> (timeoutFlush, 1)
(validateKafkaSecret, 1) -> (String, 2) -> (Equal, 2) -> (cachingEqual, 3) -> (lazyInit, 0) -> (lazyInitSlow, 0) -> (newValidationInfo, 2) -> (IsWeak, 0) -> (Equal, 3) -> (Equal, 4) -> (formatUnequalValues, 2) -> (truncatingFormat, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Flush, 0) -> (onFlush, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (printWithFileLine, 6) -> (output, 6) -> (timeoutFlush, 1)
(validateKafkaSecret, 1) -> (String, 2) -> (Reset, 0) -> (make, 2) -> (New, 1) -> (HTTPWrappersForConfig, 2) -> (NewImpersonatingRoundTripper, 2) -> (Token, 0) -> (startFrameWrite, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (FormatDiff, 2) -> (formatDiffList, 3) -> (CanInterface, 0) -> (fromString, 1) -> (waitClosed, 0)
(validateKafkaSecret, 1) -> (String, 2) -> (Reset, 0) -> (make, 2) -> (init, 0) -> (UTC, 0) -> (setCurMetricsConfig, 1) -> (setCurMetricsConfigUnlocked, 1) -> (updateClientConnState, 1) -> (UpdateClientConnState, 1) -> (UpdateAddresses, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Sign, 0) -> (UnscaledBig, 0) -> (Err, 0) -> (Proto, 0) -> (RunRaw, 2) -> (runPiped, 4) -> (runWithFriendlyError, 3) -> (run, 3) -> (runCmdContext, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (Write, 1) -> (printWithFileLine, 6) -> (output, 6) -> (timeoutFlush, 1) -> (NewEventListener, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (stringOff, 1) -> (WriteString, 1) -> (prepareNext, 1) -> (, 0) -> (NewStream, 3) -> (DurationP, 4) -> (RoundTrip, 1) -> (after, 3) -> (shouldEscape, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (String, 0) -> (URL, 1) -> (parseText, 1) -> (next, 0) -> (handleRawConn, 1) -> (removeConn, 1) -> (methodFamily, 1) -> (processStreamingRPC, 5)
(validateKafkaSecret, 1) -> (String, 2) -> (Equal, 2) -> (cachingEqual, 3) -> (lazyInit, 0) -> (lazyInitSlow, 0) -> (newValidationInfo, 2) -> (IsWeak, 0) -> (Equal, 3) -> (Equal, 4) -> (formatUnequalValues, 2) -> (truncatingFormat, 1) -> (SplitAfter, 2)
(validateKafkaSecret, 1) -> (String, 2) -> (Reset, 0) -> (make, 2) -> (, 0) -> (NewStream, 3) -> (Store, 1) -> (packError, 1) -> (Get, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (IsZero, 0) -> (Sign, 0) -> (IsNegative, 0) -> (Shutdown, 1) -> (handleRawConn, 1) -> (removeConn, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Value, 0) -> (ScaledValue, 1) -> (infScale, 0) -> (DivMod, 3) -> (DispatchMessageWithRetries, 7) -> (executeRequest, 5) -> (PassThroughHeaders, 1) -> (CheckRetry, 1) -> (truncatingFormat, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (Has, 1) -> (findJsonNameField, 1) -> (CanOmit, 1)
(validateKafkaSecret, 1) -> (String, 2) -> (Reset, 0) -> (make, 2) -> (Reset, 1) -> (resetMessage, 1) -> (SetUnknown, 1) -> (setUnknown, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (String, 0) -> (URL, 1) -> (parseText, 1) -> (next, 0) -> (consume, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Decode, 1) -> (ParseUint, 3) -> (hasRecentError, 2) -> (newCountValue, 2) -> (connect, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (IsZero, 0) -> (Sign, 0) -> (IsNegative, 0) -> (Shutdown, 1) -> (RunContext, 2) -> (processNextWorkItem, 0) -> (handleErr, 2) -> (ShuttingDown, 0) -> (AdmissionregistrationV1, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Parse, 1) -> (parseText, 1) -> (next, 0)
(validateKafkaSecret, 1) -> (String, 2) -> (Reset, 0) -> (make, 2) -> (, 0) -> (NewStream, 3) -> (Store, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Validate, 0) -> (New, 1) -> (HTTPWrappersForConfig, 2) -> (NewImpersonatingRoundTripper, 2) -> (newQueue, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Do, 1) -> (transformResponse, 2) -> (isTextResponse, 1) -> (NewGenericServerResponse, 7) -> (StartConsumerGroup, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (writeAsCSV, 1) -> (TrimSuffix, 2) -> (onFlush, 0) -> (recordDroppedTimeseries, 2) -> (LazyLog, 2) -> (addEvent, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (Write, 1) -> (printWithFileLine, 6) -> (output, 6) -> (timeoutFlush, 1) -> (NewNamedRateLimitingQueue, 2) -> (NewNamedDelayingQueue, 1) -> (NewDelayingQueueWithCustomClock, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (nextBlock, 1) -> (println, 1) -> (setPrev, 3) -> (compareSwap, 3) -> (StartConsumerGroup, 4) -> (Consume, 3) -> (release, 1) -> (topicToPartitionNumbers, 1)
(validateKafkaSecret, 1) -> (String, 2) -> (Reset, 0) -> (make, 2) -> (, 0) -> (NewStream, 3) -> (Store, 1) -> (packError, 1) -> (Authorize, 1) -> (readPackage, 1) -> (NewInitiatorWrapToken, 2) -> (SetCheckSum, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Uint64, 0) -> (Uint64, 1) -> (uint64ToRaw, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Error, 0) -> (normalized, 0) -> (mergePaths, 2) -> (containsString, 2) -> (NewEventListener, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Close, 0) -> (Broadcast, 0) -> (conversionHandler, 3) -> (Convert, 2) -> (newAsyncProducer, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (Close, 0) -> (Broadcast, 0) -> (conversionHandler, 3) -> (Convert, 2) -> (StartConsumerGroup, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Sign, 0) -> (UnscaledBig, 0) -> (Err, 0) -> (Proto, 0) -> (RunContext, 2) -> (processNextWorkItem, 0) -> (handleErr, 2) -> (ShuttingDown, 0) -> (AdmissionregistrationV1, 0) -> (newValidatingWebhookConfigurations, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Len, 0) -> (Get, 0) -> (readFileFromKoData, 1) -> (hasInformer, 0) -> (NewNamedRateLimitingQueue, 2) -> (NewNamedDelayingQueue, 1) -> (NewDelayingQueueWithCustomClock, 2)
(validateKafkaSecret, 1) -> (String, 2) -> (Equal, 2) -> (cachingEqual, 3) -> (Get, 1) -> (GetUsing, 2) -> (allocValueUnstructured, 0) -> (allocate, 0) -> (reportCount, 3) -> (ReportCRStatusEvent, 2) -> (createEvent, 2) -> (getRecorder, 4)
(validateKafkaSecret, 1) -> (String, 2) -> (Reset, 0) -> (make, 2) -> (New, 1) -> (HTTPWrappersForConfig, 2) -> (NewImpersonatingRoundTripper, 2) -> (Token, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (compressBlock, 1) -> (, 0) -> (NewStream, 3) -> (DurationP, 4) -> (NewEventListener, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (Has, 1) -> (findJsonNameField, 1) -> (CanOmit, 1) -> (isZero, 1) -> (startFrameWrite, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (stringOff, 1) -> (WriteString, 1) -> (Get, 0) -> (MatchString, 1) -> (ReadFile, 1) -> (ReadObject, 3) -> (NewNamedDelayingQueue, 1) -> (NewDelayingQueueWithCustomClock, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (nextBlock, 1) -> (println, 1) -> (setPrev, 3) -> (compareSwap, 3) -> (RoundTrip, 1) -> (after, 3) -> (shouldEscape, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (ValueOf, 1) -> (valueOfIface, 1) -> (valueOfBytes, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (String, 0) -> (URL, 1) -> (parseText, 1) -> (next, 0) -> (resolveNow, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Sign, 0) -> (UnscaledBig, 0) -> (Err, 0) -> (Proto, 0) -> (RunContext, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Sign, 0) -> (UnscaledBig, 0) -> (Err, 0) -> (Proto, 0) -> (NewContext, 0) -> (SetupSignalHandler, 0)
(validateKafkaSecret, 1) -> (String, 2) -> (Reset, 0) -> (make, 2) -> (, 0) -> (NewStream, 3) -> (Store, 1) -> (packError, 1) -> (Consume, 3) -> (release, 1) -> (topicToPartitionNumbers, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (Write, 1) -> (printWithFileLine, 6) -> (output, 6) -> (timeoutFlush, 1) -> (handleSuccess, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (prepareNext, 1) -> (append, 3) -> (BoolVar, 1) -> (typeName, 0) -> (StartConsumerGroup, 4) -> (Consume, 3)
(validateKafkaSecret, 1) -> (String, 2) -> (Reset, 0) -> (make, 2) -> (Add, 1) -> (insert, 1) -> (evict, 0) -> (evictOldest, 1) -> (Get, 2) -> (NewSharedIndexInformer, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Error, 0) -> (normalized, 0) -> (mergePaths, 2) -> (containsString, 2) -> (consume, 2) -> (waitClosed, 0) -> (WithFinish, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Get, 0) -> (MatchString, 1) -> (ReadFile, 1) -> (ReadObject, 3) -> (localHTTPCredProvider, 3) -> (Log, 3) -> (Of, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Sign, 0) -> (UnscaledBig, 0) -> (Err, 0) -> (Proto, 0) -> (Send, 2) -> (reportCount, 3) -> (ReportCRStatusEvent, 2) -> (createEvent, 2) -> (getRecorder, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (open, 0) -> (newObject, 1) -> (toObjectACLRules, 1) -> (toObjectACLRule, 1) -> (sendAndReceiveKerberos, 0) -> (Authorize, 1) -> (readPackage, 1) -> (NewInitiatorWrapToken, 2) -> (SetCheckSum, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (open, 0) -> (newObject, 1) -> (toObjectACLRules, 1) -> (toObjectACLRule, 1) -> (sendAndReceiveKerberos, 0) -> (Authorize, 1) -> (readPackage, 1) -> (NewInitiatorWrapToken, 2) -> (SetCheckSum, 2)
(validateKafkaSecret, 1) -> (String, 2) -> (Equal, 2) -> (cachingEqual, 3) -> (Range, 1) -> (extensionMap, 1) -> (handleResponse, 1) -> (handleSuccess, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (IsZero, 0) -> (Sign, 0) -> (IsNegative, 0) -> (Shutdown, 1) -> (RunContext, 2)
(validateKafkaSecret, 1) -> (String, 2) -> (Reset, 0) -> (make, 2) -> (, 0) -> (NewStream, 3) -> (Store, 1) -> (packError, 1) -> (NewContext, 0) -> (SetupSignalHandler, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Encode, 2) -> (SetGroupVersionKind, 1) -> (SetKind, 1) -> (setNestedField, 2) -> (List, 1) -> (ListFunc, 1) -> (WithPath, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Start, 0) -> (start, 0) -> (UpdateState, 1) -> (updateResolverState, 2) -> (handleSuccess, 2) -> (dropPartition, 2) -> (getBrokerProducer, 1) -> (newBrokerProducer, 1)
(validateKafkaSecret, 1) -> (String, 2) -> (Reset, 0) -> (make, 2) -> (println, 2) -> (output, 5) -> (timeoutFlush, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (IsZero, 0) -> (Sign, 0) -> (IsNegative, 0) -> (Shutdown, 1) -> (StartReceiver, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (New, 1) -> (HTTPWrappersForConfig, 2) -> (NewImpersonatingRoundTripper, 2) -> (Token, 0) -> (startFrameWrite, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (New, 1) -> (HTTPWrappersForConfig, 2) -> (NewImpersonatingRoundTripper, 2) -> (Token, 0) -> (ConfigureTransports, 1) -> (configureTransports, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Close, 0) -> (Broadcast, 0) -> (conversionHandler, 3) -> (Convert, 2) -> (Equal, 3) -> (Equal, 4) -> (formatUnequalValues, 2) -> (truncatingFormat, 1) -> (SplitAfter, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (MarshalText, 0) -> (Level, 0) -> (int8, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Sign, 0) -> (UnscaledBig, 0) -> (Err, 0) -> (Proto, 0) -> (Watch, 1) -> (WatchFunc, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Get, 0) -> (MatchString, 1) -> (ReadFile, 1) -> (ReadObject, 3) -> (combineBodyMedia, 5) -> (newMultipartReader, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (Write, 1) -> (printWithFileLine, 6) -> (output, 6) -> (timeoutFlush, 1) -> (ConfigureTransport, 1) -> (ConfigureTransports, 1) -> (configureTransports, 1) -> (addConnIfNeeded, 3)
(validateKafkaSecret, 1) -> (String, 2) -> (Reset, 0) -> (make, 2) -> (, 0) -> (NewStream, 3) -> (Store, 1) -> (packError, 1) -> (Consume, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Sign, 0) -> (UnscaledBig, 0) -> (Err, 0) -> (Proto, 0) -> (processNextWorkItem, 0) -> (handleErr, 2) -> (ShuttingDown, 0) -> (AdmissionregistrationV1, 0)
(validateKafkaSecret, 1) -> (String, 2) -> (Reset, 0) -> (make, 2) -> (init, 0) -> (UTC, 0) -> (setCurMetricsConfig, 1) -> (setCurMetricsConfigUnlocked, 1) -> (runConcurrent, 2) -> (runWithFriendlyError, 3) -> (run, 3) -> (runCmdContext, 2)
(validateKafkaSecret, 1) -> (String, 2) -> (Reset, 0) -> (make, 2) -> (startStreamDecoder, 1)
(validateKafkaSecret, 1) -> (String, 2) -> (Reset, 0) -> (make, 2) -> (New, 1) -> (HTTPWrappersForConfig, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (Encode, 2) -> (SetGroupVersionKind, 1) -> (SetKind, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (FormatDiff, 2) -> (formatDiffList, 3) -> (CanInterface, 0) -> (fromString, 1) -> (handleRawConn, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (CanonicalizeBytes, 1) -> (AsCanonicalBase1024Bytes, 1) -> (removeBigIntFactors, 2) -> (DivMod, 3) -> (asyncFlush, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Close, 0) -> (Broadcast, 0) -> (conversionHandler, 3) -> (Convert, 2) -> (NewEventListener, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (Write, 1) -> (printWithFileLine, 6) -> (output, 6) -> (timeoutFlush, 1) -> (ConfigureTransport, 1) -> (ConfigureTransports, 1) -> (configureTransports, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Call, 5) -> (RpcError_ErrorCode, 1) -> (convertInterfaceNumbers, 2) -> (convertNumber, 1) -> (retryBatch, 4) -> (getBrokerProducer, 1) -> (newBrokerProducer, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Flush, 0) -> (onFlush, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (Has, 1) -> (findJsonNameField, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Do, 1) -> (transformResponse, 2) -> (isTextResponse, 1) -> (NewGenericServerResponse, 7)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Bytes, 0) -> (BytesVar, 1) -> (newBytesValue, 1) -> (remaining, 0) -> (newQueue, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (compressBlock, 1) -> (, 0) -> (NewStream, 3) -> (DurationP, 4) -> (StartConsumerGroup, 4) -> (Consume, 3) -> (release, 1) -> (topicToPartitionNumbers, 1) -> (Partitions, 1)
(validateKafkaSecret, 1) -> (String, 2) -> (Reset, 0) -> (make, 2) -> (, 0) -> (NewStream, 3) -> (Store, 1) -> (packError, 1) -> (Equal, 3) -> (Equal, 4) -> (formatUnequalValues, 2) -> (truncatingFormat, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (String, 0) -> (URL, 1) -> (parseText, 1) -> (next, 0) -> (handleRawConn, 1) -> (removeConn, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (String, 0) -> (URL, 1) -> (parseText, 1) -> (next, 0) -> (LazyLog, 2) -> (addEvent, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (nextBlock, 1) -> (println, 1) -> (setPrev, 3) -> (compareSwap, 3) -> (StartConsumerGroup, 4) -> (Consume, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (ValueOf, 1) -> (valueOfIface, 1) -> (valueOfBytes, 1) -> (newValidationInfo, 2) -> (getLoggingConfig, 1) -> (ConfigToJSON, 1) -> (levelFromString, 1) -> (lex, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (compressBlock, 1) -> (, 0) -> (NewStream, 3) -> (DurationP, 4) -> (RoundTrip, 1) -> (after, 3) -> (shouldEscape, 1) -> (legalHeaderByte, 1) -> (GroupVersions, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (String, 0) -> (URL, 1) -> (parseText, 1) -> (next, 0) -> (Attack, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (compressBlock, 1) -> (, 0) -> (NewStream, 3) -> (DurationP, 4) -> (poller, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Flush, 0) -> (onFlush, 0) -> (recordDroppedTimeseries, 2) -> (isMyEvent, 1) -> (LazyLog, 2) -> (addEvent, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (String, 0) -> (URL, 1) -> (parseText, 1) -> (next, 0) -> (tryAllAddrs, 2) -> (updateConnectionError, 1) -> (NewClientTransport, 7) -> (newHTTP2Client, 7)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Sign, 0) -> (UnscaledBig, 0) -> (Err, 0) -> (Proto, 0) -> (StartReceiver, 2) -> (Invoke, 3)
(validateKafkaSecret, 1) -> (String, 2) -> (AsStringSlice, 1) -> (Index, 1) -> (Get, 0) -> (MatchString, 1) -> (ReadFile, 1) -> (ReadObject, 3) -> (NewNamedDelayingQueue, 1) -> (NewDelayingQueueWithCustomClock, 2)
(validateKafkaSecret, 1) -> (String, 2) -> (Equal, 2) -> (cachingEqual, 3) -> (Get, 1) -> (GetUsing, 2) -> (allocValueUnstructured, 0) -> (allocate, 0) -> (NewNamedDelayingQueue, 1) -> (NewDelayingQueueWithCustomClock, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (String, 0) -> (URL, 1) -> (parseText, 1) -> (next, 0) -> (RemoteCredProvider, 2) -> (ec2RoleProvider, 2) -> (EndpointFor, 2) -> (Of, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (Get, 0) -> (MatchString, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Has, 1) -> (findJsonNameField, 1) -> (CanOmit, 1) -> (isZero, 1) -> (NewEventListener, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (String, 0) -> (URL, 1) -> (parseText, 1) -> (next, 0) -> (StartSteps, 2) -> (ExecutePace, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Write, 1) -> (printWithFileLine, 6) -> (output, 6) -> (timeoutFlush, 1) -> (LazyPrintf, 2) -> (addEvent, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Sign, 0) -> (UnscaledBig, 0) -> (Err, 0) -> (Proto, 0) -> (contextForChannel, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Start, 0) -> (start, 0) -> (UpdateState, 1) -> (updateResolverState, 2) -> (NewEventListener, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (Write, 1) -> (printWithFileLine, 6) -> (output, 6) -> (timeoutFlush, 1) -> (combineBodyMedia, 5) -> (newMultipartReader, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Validate, 0) -> (New, 1) -> (HTTPWrappersForConfig, 2) -> (NewImpersonatingRoundTripper, 2) -> (NewNamedRateLimitingQueue, 2) -> (NewNamedDelayingQueue, 1) -> (NewDelayingQueueWithCustomClock, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (stringOff, 1) -> (WriteString, 1) -> (prepareNext, 1) -> (, 0) -> (NewStream, 3) -> (DurationP, 4) -> (StartConsumerGroup, 4) -> (Consume, 3) -> (release, 1) -> (topicToPartitionNumbers, 1) -> (Partitions, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (nextBlock, 1) -> (println, 1) -> (setPrev, 3) -> (compareSwap, 3) -> (StartConsumerGroup, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (nextBlock, 1) -> (println, 1) -> (setPrev, 3) -> (compareSwap, 3) -> (NewEventListener, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (compressBlock, 1) -> (, 0) -> (NewStream, 3) -> (DurationP, 4) -> (StartConsumerGroup, 4) -> (Consume, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (String, 0) -> (URL, 1) -> (parseText, 1) -> (next, 0) -> (updateResolverState, 2) -> (updateClientConnState, 1) -> (UpdateClientConnState, 1)
(validateKafkaSecret, 1) -> (String, 2) -> (AsStringSlice, 1) -> (Index, 1) -> (Get, 0) -> (MatchString, 1) -> (ReadFile, 1) -> (ReadObject, 3) -> (executeCredentialProcess, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (stringOff, 1) -> (WriteString, 1) -> (prepareNext, 1) -> (, 0) -> (NewStream, 3) -> (DurationP, 4) -> (StartConsumerGroup, 4) -> (Consume, 3) -> (release, 1) -> (topicToPartitionNumbers, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Start, 0)
(validateKafkaSecret, 1) -> (String, 2) -> (Equal, 2) -> (cachingEqual, 3) -> (lazyInit, 0) -> (lazyInitSlow, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Len, 0) -> (Get, 0) -> (readFileFromKoData, 1) -> (hasInformer, 0) -> (asyncFlush, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Do, 1) -> (transformResponse, 2) -> (isTextResponse, 1) -> (NewGenericServerResponse, 7) -> (Build, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (IsZero, 0) -> (Sign, 0) -> (IsNegative, 0) -> (Shutdown, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (open, 0) -> (newObject, 1) -> (toObjectACLRules, 1) -> (toObjectACLRule, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (prepareNext, 1) -> (append, 3) -> (BoolVar, 1) -> (typeName, 0) -> (poller, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (prepareNext, 1) -> (append, 3) -> (BoolVar, 1) -> (typeName, 0) -> (Build, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (open, 0)
(validateKafkaSecret, 1) -> (String, 2) -> (Reset, 0) -> (make, 2) -> (Reset, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Error, 0) -> (normalized, 0) -> (mergePaths, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Validate, 0) -> (New, 1) -> (HTTPWrappersForConfig, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (MarshalText, 0) -> (Level, 0) -> (int8, 1) -> (loggerOptionFunc, 1) -> (handleSuccess, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Bytes, 0) -> (BytesVar, 1) -> (newBytesValue, 1) -> (remaining, 0) -> (consume, 2) -> (waitClosed, 0) -> (WithFinish, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (nextBlock, 1) -> (println, 1) -> (setPrev, 3) -> (compareSwap, 3) -> (StartConsumerGroup, 4) -> (Consume, 3) -> (release, 1) -> (topicToPartitionNumbers, 1) -> (Partitions, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Start, 0) -> (start, 0) -> (UpdateState, 1) -> (updateResolverState, 2) -> (updateClientConnState, 1) -> (UpdateClientConnState, 1) -> (UpdateAddresses, 1) -> (newAddrConn, 2) -> (RegisterSubChannel, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (compressBlock, 1) -> (, 0) -> (NewStream, 3) -> (DurationP, 4) -> (sendAndReceiveKerberos, 0) -> (Authorize, 1) -> (readPackage, 1) -> (NewInitiatorWrapToken, 2) -> (SetCheckSum, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (Write, 1) -> (printWithFileLine, 6)
(validateKafkaSecret, 1) -> (String, 2) -> (Reset, 0) -> (make, 2) -> (, 0) -> (NewStream, 3) -> (Store, 1) -> (packError, 1) -> (roundTrip, 1) -> (handleReadLoopResponse, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Start, 0) -> (start, 0) -> (UpdateState, 1) -> (updateResolverState, 2) -> (getLoggingConfig, 1) -> (ConfigToJSON, 1) -> (levelFromString, 1) -> (lex, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Bytes, 0) -> (BytesVar, 1) -> (newBytesValue, 1) -> (remaining, 0) -> (consume, 2) -> (waitClosed, 0) -> (WithFinish, 2) -> (MarkOffset, 4) -> (MarkOffset, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Error, 0) -> (normalized, 0) -> (mergePaths, 2) -> (containsString, 2) -> (consume, 2) -> (waitClosed, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Get, 0) -> (MatchString, 1) -> (ReadFile, 1) -> (ReadObject, 3) -> (localHTTPCredProvider, 3) -> (httpCredProvider, 3) -> (NewProviderClient, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (FormatDiff, 2) -> (formatDiffList, 3) -> (CanInterface, 0) -> (fromString, 1) -> (handleRawConn, 1) -> (removeConn, 1) -> (methodFamily, 1) -> (processStreamingRPC, 5)
(validateKafkaSecret, 1) -> (String, 2) -> (AsStringSlice, 1) -> (Index, 1) -> (Get, 0) -> (MatchString, 1)
(validateKafkaSecret, 1) -> (String, 2) -> (Reset, 0) -> (make, 2) -> (Add, 1) -> (insert, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Start, 0) -> (start, 0) -> (UpdateState, 1) -> (updateResolverState, 2) -> (asyncFlush, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (rotateFile, 1) -> (Version, 0) -> (Version, 1) -> (Flag, 2) -> (Cleanup, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (prepareNext, 1) -> (append, 3) -> (BoolVar, 1) -> (typeName, 0) -> (handleRawConn, 1) -> (removeConn, 1) -> (methodFamily, 1) -> (processStreamingRPC, 5)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (FormatDiff, 2) -> (formatDiffList, 3) -> (CanInterface, 0) -> (fromString, 1) -> (StartConsumerGroup, 4) -> (Consume, 3) -> (release, 1) -> (topicToPartitionNumbers, 1) -> (Partitions, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Uint16, 0) -> (Uint16, 1) -> (EnsureSpace, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (nextBlock, 1) -> (println, 1) -> (setPrev, 3) -> (compareSwap, 3) -> (Cleanup, 1)
(validateKafkaSecret, 1) -> (String, 2) -> (Reset, 0) -> (make, 2) -> (Add, 1) -> (insert, 1) -> (evict, 0) -> (evictOldest, 1) -> (startFrameWrite, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (New, 1) -> (HTTPWrappersForConfig, 2) -> (NewImpersonatingRoundTripper, 2) -> (Token, 0) -> (ConfigureTransports, 1) -> (configureTransports, 1) -> (addConnIfNeeded, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (FormatDiff, 2) -> (formatDiffList, 3) -> (CanInterface, 0) -> (fromString, 1) -> (newAsyncProducer, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (FormatDiff, 2) -> (formatDiffList, 3) -> (CanInterface, 0) -> (fromString, 1) -> (NewEventListener, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (nextBlock, 1) -> (println, 1) -> (setPrev, 3) -> (compareSwap, 3) -> (Build, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (String, 0) -> (URL, 1) -> (parseText, 1) -> (next, 0) -> (RunRaw, 2) -> (runPiped, 4) -> (runWithFriendlyError, 3) -> (run, 3) -> (runCmdContext, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Do, 1) -> (transformResponse, 2) -> (isTextResponse, 1)
(validateKafkaSecret, 1) -> (String, 2) -> (Reset, 0) -> (make, 2) -> (New, 1) -> (HTTPWrappersForConfig, 2) -> (NewImpersonatingRoundTripper, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Has, 1) -> (findJsonNameField, 1) -> (CanOmit, 1) -> (isZero, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (FormatDiff, 2) -> (formatDiffList, 3) -> (CanInterface, 0) -> (fromString, 1) -> (asyncFlush, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Error, 0) -> (normalized, 0) -> (mergePaths, 2) -> (containsString, 2) -> (consume, 2) -> (waitClosed, 0) -> (WithFinish, 2) -> (MarkOffset, 4) -> (MarkOffset, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Close, 0) -> (Broadcast, 0) -> (conversionHandler, 3) -> (Convert, 2) -> (RoundTrip, 1) -> (after, 3) -> (shouldEscape, 1) -> (legalHeaderByte, 1) -> (GroupVersions, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Has, 1) -> (findJsonNameField, 1) -> (CanOmit, 1) -> (isZero, 1) -> (DispatchMessageWithRetries, 7) -> (executeRequest, 5) -> (PassThroughHeaders, 1) -> (CheckRetry, 1) -> (truncatingFormat, 1) -> (detectRaces, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (write, 3) -> (width, 1) -> (yaml_emitter_set_writer_error, 2) -> (NewImpersonatingRoundTripper, 2) -> (NewNamedRateLimitingQueue, 2) -> (NewNamedDelayingQueue, 1) -> (NewDelayingQueueWithCustomClock, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (FormatDiff, 2) -> (formatDiffList, 3) -> (CanInterface, 0) -> (fromString, 1) -> (RoundTrip, 1) -> (after, 3) -> (shouldEscape, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Get, 0) -> (MatchString, 1) -> (ReadFile, 1) -> (ReadObject, 3) -> (retryBatch, 4) -> (getBrokerProducer, 1) -> (newBrokerProducer, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (Close, 0) -> (Broadcast, 0) -> (conversionHandler, 3) -> (Convert, 2) -> (StartConsumerGroup, 4) -> (Consume, 3) -> (release, 1) -> (topicToPartitionNumbers, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (prepareNext, 1) -> (append, 3) -> (BoolVar, 1) -> (typeName, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (Write, 1) -> (printWithFileLine, 6) -> (output, 6) -> (timeoutFlush, 1) -> (Cleanup, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Error, 0) -> (normalized, 0) -> (mergePaths, 2) -> (containsString, 2) -> (Cleanup, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Close, 0) -> (Broadcast, 0) -> (conversionHandler, 3) -> (Convert, 2) -> (startFrameWrite, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Error, 0) -> (normalized, 0) -> (mergePaths, 2) -> (containsString, 2) -> (ConfigureTransport, 1) -> (ConfigureTransports, 1) -> (configureTransports, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (nextBlock, 1) -> (println, 1) -> (setPrev, 3) -> (compareSwap, 3) -> (RoundTrip, 1) -> (after, 3) -> (shouldEscape, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Write, 1) -> (printWithFileLine, 6) -> (output, 6) -> (timeoutFlush, 1) -> (ConfigureTransport, 1) -> (ConfigureTransports, 1) -> (configureTransports, 1) -> (addConnIfNeeded, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Write, 1) -> (printWithFileLine, 6) -> (output, 6) -> (timeoutFlush, 1) -> (DispatchMessageWithRetries, 7) -> (executeRequest, 5) -> (PassThroughHeaders, 1) -> (CheckRetry, 1) -> (truncatingFormat, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Encode, 2) -> (SetGroupVersionKind, 1) -> (SetKind, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Sort, 1) -> (Compare, 2) -> (CompareUsing, 3) -> (IsNull, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Close, 0) -> (Broadcast, 0) -> (conversionHandler, 3) -> (Convert, 2) -> (Cleanup, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Start, 0) -> (start, 0) -> (UpdateState, 1) -> (updateResolverState, 2) -> (applyServiceConfigAndBalancer, 3) -> (newCCBalancerWrapper, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Sign, 0) -> (UnscaledBig, 0) -> (Err, 0) -> (Proto, 0) -> (serveStreams, 1) -> (methodFamily, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (compressBlock, 1) -> (, 0) -> (NewStream, 3) -> (DurationP, 4) -> (StartConsumerGroup, 4) -> (Consume, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (FormatDiff, 2) -> (formatDiffList, 3) -> (CanInterface, 0) -> (fromString, 1) -> (sendAndReceiveKerberos, 0) -> (Authorize, 1) -> (readPackage, 1) -> (NewInitiatorWrapToken, 2) -> (SetCheckSum, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Encode, 2) -> (SetGroupVersionKind, 1) -> (SetKind, 1) -> (setNestedField, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (Call, 5) -> (RpcError_ErrorCode, 1) -> (convertInterfaceNumbers, 2) -> (convertNumber, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (prepareNext, 1) -> (append, 3) -> (BoolVar, 1) -> (typeName, 0) -> (handleRawConn, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (ValueOf, 1) -> (valueOfIface, 1) -> (valueOfBytes, 1) -> (newValidationInfo, 2) -> (newQueue, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Start, 0) -> (start, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (String, 0) -> (URL, 1) -> (parseText, 1) -> (next, 0) -> (PollUntil, 3) -> (WaitFor, 3)
(validateKafkaSecret, 1) -> (String, 2) -> (Reset, 0) -> (make, 2) -> (, 0) -> (NewStream, 3) -> (Store, 1) -> (packError, 1) -> (Get, 2) -> (NewSharedIndexInformer, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (FullPath, 0) -> (Free, 0) -> (unref, 0) -> (freeTrace, 1) -> (handleSuccess, 2) -> (dropPartition, 2) -> (getBrokerProducer, 1) -> (newBrokerProducer, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (compressBlock, 1) -> (, 0) -> (NewStream, 3) -> (DurationP, 4) -> (getLoggingConfig, 1) -> (ConfigToJSON, 1) -> (levelFromString, 1) -> (lex, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Validate, 0) -> (New, 1) -> (HTTPWrappersForConfig, 2) -> (NewImpersonatingRoundTripper, 2) -> (asyncFlush, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Encode, 2) -> (SetGroupVersionKind, 1) -> (SetKind, 1) -> (setNestedField, 2) -> (poller, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (String, 0) -> (URL, 1) -> (parseText, 1) -> (next, 0) -> (updateResolverState, 2) -> (updateClientConnState, 1) -> (UpdateClientConnState, 1) -> (UpdateAddresses, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Error, 0) -> (normalized, 0) -> (mergePaths, 2) -> (containsString, 2) -> (ConfigureTransport, 1) -> (ConfigureTransports, 1) -> (configureTransports, 1) -> (addConnIfNeeded, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (IsZero, 0) -> (Sign, 0) -> (IsNegative, 0) -> (Shutdown, 1) -> (getContext, 0) -> (NewContext, 0) -> (SetupSignalHandler, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Start, 0) -> (start, 0) -> (UpdateState, 1) -> (updateResolverState, 2) -> (DispatchMessageWithRetries, 7) -> (executeRequest, 5) -> (PassThroughHeaders, 1) -> (CheckRetry, 1) -> (truncatingFormat, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (Close, 0) -> (Broadcast, 0) -> (conversionHandler, 3) -> (Convert, 2) -> (sendAndReceiveKerberos, 0) -> (Authorize, 1) -> (readPackage, 1) -> (NewInitiatorWrapToken, 2) -> (SetCheckSum, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Error, 0) -> (normalized, 0) -> (mergePaths, 2) -> (containsString, 2) -> (getLoggingConfig, 1) -> (ConfigToJSON, 1) -> (levelFromString, 1) -> (lex, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (prepareNext, 1) -> (append, 3) -> (BoolVar, 1) -> (typeName, 0) -> (sendAndReceiveKerberos, 0) -> (Authorize, 1) -> (readPackage, 1) -> (NewInitiatorWrapToken, 2) -> (SetCheckSum, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (FormatDiff, 2) -> (formatDiffList, 3) -> (CanInterface, 0) -> (fromString, 1) -> (DispatchMessageWithRetries, 7) -> (executeRequest, 5) -> (PassThroughHeaders, 1) -> (CheckRetry, 1) -> (truncatingFormat, 1) -> (detectRaces, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (withDeadline, 2) -> (WithDeadline, 2) -> (AfterFunc, 2) -> (removeChild, 2)
(validateKafkaSecret, 1) -> (String, 2) -> (Reset, 0) -> (make, 2) -> (init, 0) -> (UTC, 0) -> (setCurMetricsConfig, 1) -> (setCurMetricsConfigUnlocked, 1) -> (NewContext, 0) -> (SetupSignalHandler, 0)
(validateKafkaSecret, 1) -> (String, 2) -> (Equal, 2) -> (cachingEqual, 3) -> (Get, 1) -> (GetUsing, 2) -> (allocValueUnstructured, 0) -> (allocate, 0) -> (retryBatch, 4) -> (getBrokerProducer, 1) -> (newBrokerProducer, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Write, 1) -> (printWithFileLine, 6) -> (output, 6) -> (timeoutFlush, 1) -> (getLoggingConfig, 1) -> (ConfigToJSON, 1) -> (levelFromString, 1) -> (lex, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Decode, 1) -> (ParseUint, 3) -> (hasRecentError, 2) -> (newCountValue, 2) -> (newConsumerGroupClaim, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Start, 0) -> (start, 0) -> (UpdateState, 1) -> (updateResolverState, 2) -> (newAsyncProducer, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (FullPath, 0) -> (Free, 0) -> (unref, 0) -> (freeTrace, 1) -> (Retrieve, 0) -> (profile, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Len, 0) -> (Get, 0) -> (readFileFromKoData, 1) -> (hasInformer, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (compressBlock, 1) -> (, 0) -> (NewStream, 3) -> (DurationP, 4)
(validateKafkaSecret, 1) -> (String, 2) -> (Equal, 2) -> (cachingEqual, 3) -> (Get, 1) -> (GetUsing, 2) -> (allocValueUnstructured, 0) -> (allocate, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (FormatDiff, 2) -> (formatDiffList, 3) -> (CanInterface, 0) -> (fromString, 1) -> (newConsumerGroupClaim, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (write, 3) -> (width, 1) -> (yaml_emitter_set_writer_error, 2) -> (NewImpersonatingRoundTripper, 2) -> (ConfigureTransport, 1) -> (ConfigureTransports, 1) -> (configureTransports, 1)
(validateKafkaSecret, 1) -> (String, 2) -> (Reset, 0) -> (make, 2) -> (init, 0) -> (UTC, 0) -> (setCurMetricsConfig, 1) -> (setCurMetricsConfigUnlocked, 1) -> (updateClientConnState, 1) -> (UpdateClientConnState, 1) -> (UpdateAddresses, 1) -> (newAddrConn, 2) -> (RegisterSubChannel, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (compressBlock, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Close, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (String, 0) -> (URL, 1) -> (parseText, 1) -> (next, 0) -> (createTraceServiceConnection, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Len, 0) -> (Get, 0) -> (readFileFromKoData, 1) -> (hasInformer, 0) -> (Retrieve, 0) -> (profile, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Validate, 0) -> (New, 1) -> (HTTPWrappersForConfig, 2) -> (NewImpersonatingRoundTripper, 2) -> (connect, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Sign, 0) -> (UnscaledBig, 0) -> (Err, 0) -> (Proto, 0) -> (serveStreams, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Start, 0) -> (start, 0) -> (UpdateState, 1) -> (updateResolverState, 2) -> (ConfigureTransport, 1) -> (ConfigureTransports, 1) -> (configureTransports, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (Call, 5) -> (RpcError_ErrorCode, 1) -> (convertInterfaceNumbers, 2) -> (convertNumber, 1) -> (retryBatch, 4) -> (getBrokerProducer, 1) -> (newBrokerProducer, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Uint32, 0) -> (Uint32, 1) -> (uint32ToRaw, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Reset, 1) -> (resetMessage, 1) -> (SetUnknown, 1) -> (setUnknown, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (stringOff, 1) -> (WriteString, 1) -> (Get, 0) -> (MatchString, 1) -> (ReadFile, 1) -> (ReadObject, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (String, 0) -> (URL, 1) -> (parseText, 1) -> (next, 0) -> (startHealthCheck, 1)
(validateKafkaSecret, 1) -> (String, 2) -> (Reset, 0) -> (make, 2) -> (init, 0) -> (UTC, 0) -> (setCurMetricsConfig, 1) -> (setCurMetricsConfigUnlocked, 1) -> (runPiped, 4) -> (runWithFriendlyError, 3) -> (run, 3) -> (runCmdContext, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (FormatDiff, 2) -> (formatDiffList, 3) -> (CanInterface, 0) -> (fromString, 1) -> (poller, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Flush, 0) -> (onFlush, 0) -> (recordDroppedTimeseries, 2) -> (isMyEvent, 1) -> (addEvent, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (open, 0) -> (newObject, 1) -> (toObjectACLRules, 1) -> (toObjectACLRule, 1) -> (StartConsumerGroup, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (stringOff, 1) -> (WriteString, 1) -> (Get, 0) -> (MatchString, 1) -> (ReadFile, 1) -> (ReadObject, 3) -> (startFrameWrite, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (open, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (nextBlock, 1)
(validateKafkaSecret, 1) -> (String, 2) -> (Reset, 0) -> (make, 2) -> (, 0) -> (NewStream, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (compressBlock, 1) -> (, 0) -> (NewStream, 3) -> (DurationP, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (stringOff, 1) -> (WriteString, 1) -> (prepareNext, 1) -> (, 0) -> (NewStream, 3) -> (DurationP, 4) -> (Build, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Start, 0) -> (start, 0) -> (UpdateState, 1) -> (updateResolverState, 2) -> (applyServiceConfigAndBalancer, 3) -> (newCCBalancerWrapper, 3) -> (Build, 2)
(validateKafkaSecret, 1) -> (String, 2) -> (AsStringSlice, 1) -> (Index, 1) -> (lazyInit, 0) -> (lazyInitSlow, 0) -> (newValidationInfo, 2) -> (IsWeak, 0) -> (NewConfigFromMap, 1) -> (levelFromString, 1) -> (lex, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (String, 0) -> (URL, 1) -> (parseText, 1) -> (next, 0) -> (Send, 2) -> (reportCount, 3) -> (ReportCRStatusEvent, 2) -> (createEvent, 2) -> (getRecorder, 4) -> (NewRecorder, 2) -> (recordToSink, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (open, 0) -> (newObject, 1) -> (toObjectACLRules, 1) -> (toObjectACLRule, 1) -> (poller, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (Encode, 2) -> (SetGroupVersionKind, 1) -> (SetKind, 1) -> (setNestedField, 2) -> (poller, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (String, 0) -> (URL, 1) -> (parseText, 1) -> (next, 0) -> (Retrieve, 0) -> (profile, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Error, 0) -> (normalized, 0) -> (mergePaths, 2) -> (containsString, 2) -> (combineBodyMedia, 5) -> (newMultipartReader, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Reset, 1) -> (resetMessage, 1) -> (SetUnknown, 1)
(validateKafkaSecret, 1) -> (String, 2) -> (Reset, 0) -> (make, 2) -> (Reset, 1) -> (resetMessage, 1) -> (SetUnknown, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Sign, 0) -> (UnscaledBig, 0) -> (Err, 0) -> (Proto, 0) -> (Attack, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Value, 0) -> (ScaledValue, 1) -> (infScale, 0) -> (DivMod, 3) -> (newQueue, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (FormatDiff, 2) -> (formatDiffList, 3) -> (CanInterface, 0) -> (fromString, 1) -> (consume, 2) -> (waitClosed, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Write, 1) -> (printWithFileLine, 6) -> (output, 6) -> (timeoutFlush, 1) -> (NewNamedRateLimitingQueue, 2) -> (NewNamedDelayingQueue, 1) -> (NewDelayingQueueWithCustomClock, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (FullPath, 0) -> (Free, 0) -> (unref, 0) -> (freeTrace, 1) -> (RemoteCredProvider, 2) -> (ec2RoleProvider, 2) -> (EndpointFor, 2) -> (Of, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (New, 1) -> (HTTPWrappersForConfig, 2) -> (NewImpersonatingRoundTripper, 2) -> (Token, 0) -> (sendAndReceiveKerberos, 0) -> (Authorize, 1) -> (readPackage, 1) -> (NewInitiatorWrapToken, 2) -> (SetCheckSum, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Sign, 0) -> (UnscaledBig, 0) -> (Err, 0) -> (Proto, 0) -> (openBreaker, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Value, 0) -> (ScaledValue, 1) -> (infScale, 0) -> (DivMod, 3) -> (NewEventListener, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (prepareNext, 1) -> (append, 3) -> (BoolVar, 1) -> (typeName, 0) -> (handleRawConn, 1) -> (removeConn, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (FormatDiff, 2) -> (formatDiffList, 3) -> (CanInterface, 0) -> (fromString, 1) -> (consume, 2) -> (waitClosed, 0) -> (WithFinish, 2)
(validateKafkaSecret, 1) -> (String, 2) -> (AsStringSlice, 1) -> (Index, 1) -> (Get, 0) -> (MatchString, 1) -> (ReadFile, 1) -> (ReadObject, 3) -> (startFrameWrite, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (IsZero, 0) -> (Sign, 0) -> (IsNegative, 0) -> (Shutdown, 1) -> (SetupHelper, 4) -> (GetSlackChannels, 1)
(validateKafkaSecret, 1) -> (String, 2) -> (AsStringSlice, 1) -> (Index, 1) -> (Get, 0) -> (MatchString, 1) -> (ReadFile, 1) -> (ReadObject, 3) -> (ConfigureTransports, 1) -> (configureTransports, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Write, 1) -> (printWithFileLine, 6) -> (output, 6) -> (timeoutFlush, 1) -> (RemoteCredProvider, 2) -> (ec2RoleProvider, 2) -> (EndpointFor, 2) -> (Of, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (Now, 0) -> (Add, 1) -> (PushFunc, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Decode, 1) -> (ParseUint, 3) -> (hasRecentError, 2) -> (newCountValue, 2) -> (asyncFlush, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (open, 0) -> (newObject, 1) -> (toObjectACLRules, 1) -> (toObjectACLRule, 1) -> (connect, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (stringOff, 1) -> (WriteString, 1) -> (prepareNext, 1) -> (, 0) -> (NewStream, 3) -> (DurationP, 4) -> (poller, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Len, 0) -> (Get, 0) -> (readFileFromKoData, 1) -> (hasInformer, 0) -> (ConfigureTransport, 1) -> (ConfigureTransports, 1) -> (configureTransports, 1) -> (addConnIfNeeded, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (String, 0) -> (URL, 1) -> (parseText, 1) -> (next, 0) -> (handleResponse, 2) -> (awaitRequestCancel, 1)
(validateKafkaSecret, 1) -> (String, 2) -> (Equal, 2) -> (cachingEqual, 3) -> (Range, 1) -> (extensionMap, 1) -> (handleResponse, 1) -> (handleSuccess, 2) -> (ConfigureTransports, 1) -> (configureTransports, 1) -> (addConnIfNeeded, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Close, 0) -> (Broadcast, 0) -> (conversionHandler, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (write, 1) -> (put, 1) -> (executeAndPut, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (Write, 2) -> (WriteFile, 4) -> (RaceReadRange, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Get, 0) -> (MatchString, 1) -> (ReadFile, 1) -> (ReadObject, 3) -> (executeCredentialProcess, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (String, 0) -> (URL, 1) -> (parseText, 1) -> (next, 0) -> (RunContext, 2) -> (processNextWorkItem, 0) -> (handleErr, 2) -> (ShuttingDown, 0) -> (AdmissionregistrationV1, 0) -> (newValidatingWebhookConfigurations, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (String, 0) -> (URL, 1) -> (parseText, 1) -> (next, 0) -> (updateResolverState, 2) -> (updateClientConnState, 1) -> (UpdateClientConnState, 1) -> (UpdateAddresses, 1) -> (newAddrConn, 2) -> (RegisterSubChannel, 3) -> (addSubChannel, 4) -> (GetFallbackResponse, 0) -> (newClientStream, 5)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (New, 1) -> (HTTPWrappersForConfig, 2) -> (NewImpersonatingRoundTripper, 2) -> (Token, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (compressBlock, 1) -> (, 0) -> (NewStream, 3) -> (DurationP, 4) -> (Build, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Write, 1) -> (printWithFileLine, 6) -> (output, 6) -> (timeoutFlush, 1) -> (LazyLog, 2) -> (addEvent, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Sign, 0) -> (UnscaledBig, 0) -> (Err, 0) -> (Proto, 0) -> (LazyPrintf, 2) -> (addEvent, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (stringOff, 1) -> (WriteString, 1) -> (prepareNext, 1) -> (, 0) -> (NewStream, 3) -> (DurationP, 4) -> (StartConsumerGroup, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (write, 3) -> (width, 1) -> (yaml_emitter_set_writer_error, 2) -> (NewImpersonatingRoundTripper, 2) -> (ConfigureTransport, 1) -> (ConfigureTransports, 1) -> (configureTransports, 1) -> (addConnIfNeeded, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Decode, 1) -> (ParseUint, 3) -> (hasRecentError, 2) -> (newCountValue, 2) -> (newConsumerGroupClaim, 4) -> (ConsumePartition, 3) -> (refBrokerConsumer, 1) -> (newBrokerConsumer, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (String, 0) -> (URL, 1) -> (parseText, 1) -> (next, 0) -> (Send, 2) -> (reportCount, 3) -> (ReportCRStatusEvent, 2) -> (createEvent, 2) -> (getRecorder, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Sub, 1) -> (AsDec, 0) -> (SetScale, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (write, 3) -> (width, 1) -> (yaml_emitter_set_writer_error, 2) -> (NewImpersonatingRoundTripper, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (write, 3) -> (width, 1) -> (yaml_emitter_set_writer_error, 2) -> (NewImpersonatingRoundTripper, 2) -> (newQueue, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (ValueOf, 1) -> (valueOfIface, 1) -> (valueOfBytes, 1) -> (newValidationInfo, 2) -> (asyncFlush, 1)
(validateKafkaSecret, 1) -> (String, 2) -> (Reset, 0) -> (make, 2) -> (New, 1) -> (HTTPWrappersForConfig, 2) -> (NewImpersonatingRoundTripper, 2) -> (Token, 0) -> (ConfigureTransports, 1) -> (configureTransports, 1) -> (addConnIfNeeded, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Close, 0) -> (Broadcast, 0) -> (conversionHandler, 3) -> (Convert, 2) -> (NewTracingConfigFromConfigMap, 1) -> (NewTracingConfigFromMap, 1) -> (AsFloat64, 2) -> (lex, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Sign, 0) -> (UnscaledBig, 0) -> (Err, 0) -> (Proto, 0) -> (poller, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Sign, 0) -> (UnscaledBig, 0) -> (Err, 0) -> (Proto, 0) -> (newQueue, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (String, 0) -> (URL, 1) -> (parseText, 1) -> (next, 0) -> (List, 1) -> (ListFunc, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (Close, 0) -> (Broadcast, 0) -> (conversionHandler, 3) -> (Convert, 2) -> (StartConsumerGroup, 4) -> (Consume, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (Flush, 0) -> (onFlush, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (ValueOf, 1) -> (valueOfIface, 1) -> (valueOfBytes, 1) -> (newValidationInfo, 2) -> (NewEventListener, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Do, 1) -> (transformResponse, 2) -> (isTextResponse, 1) -> (NewGenericServerResponse, 7) -> (newMultipartReader, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Start, 0) -> (start, 0) -> (UpdateState, 1) -> (updateResolverState, 2) -> (updateClientConnState, 1) -> (UpdateClientConnState, 1) -> (UpdateAddresses, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Do, 1) -> (transformResponse, 2) -> (isTextResponse, 1) -> (NewGenericServerResponse, 7) -> (poller, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (Flush, 0) -> (onFlush, 0) -> (recordDroppedTimeseries, 2) -> (isMyEvent, 1) -> (addEvent, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (compressBlock, 1) -> (, 0) -> (NewStream, 3) -> (DurationP, 4) -> (newAsyncProducer, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (open, 0) -> (newObject, 1) -> (toObjectACLRules, 1) -> (toObjectACLRule, 1) -> (RoundTrip, 1) -> (after, 3) -> (shouldEscape, 1)
(validateKafkaSecret, 1) -> (String, 2) -> (AsStringSlice, 1) -> (Index, 1) -> (lazyInit, 0) -> (lazyInitSlow, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Bytes, 0) -> (BytesVar, 1) -> (newBytesValue, 1)
(validateKafkaSecret, 1) -> (String, 2) -> (Equal, 2) -> (cachingEqual, 3) -> (lazyInit, 0) -> (lazyInitSlow, 0) -> (newValidationInfo, 2) -> (IsWeak, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (String, 0) -> (URL, 1) -> (parseText, 1) -> (next, 0) -> (handleRawConn, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Decode, 1) -> (ParseUint, 3) -> (hasRecentError, 2) -> (newCountValue, 2) -> (ConfigureTransport, 1) -> (ConfigureTransports, 1) -> (configureTransports, 1) -> (addConnIfNeeded, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (FormatDiff, 2) -> (formatDiffList, 3) -> (CanInterface, 0) -> (fromString, 1) -> (RoundTrip, 1) -> (after, 3) -> (shouldEscape, 1) -> (legalHeaderByte, 1) -> (RelativizePathWithNoBacksteps, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Close, 0) -> (Broadcast, 0) -> (conversionHandler, 3) -> (Convert, 2) -> (DispatchMessageWithRetries, 7) -> (executeRequest, 5) -> (PassThroughHeaders, 1) -> (CheckRetry, 1) -> (truncatingFormat, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (Write, 1) -> (printWithFileLine, 6) -> (output, 6) -> (timeoutFlush, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Parse, 1) -> (parseText, 1) -> (next, 0) -> (fill, 1) -> (newQueue, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Has, 1) -> (findJsonNameField, 1) -> (CanOmit, 1) -> (isZero, 1) -> (startFrameWrite, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (compressBlock, 1) -> (, 0) -> (NewStream, 3) -> (DurationP, 4) -> (StartConsumerGroup, 4) -> (Consume, 3) -> (release, 1) -> (topicToPartitionNumbers, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (String, 0) -> (URL, 1) -> (parseText, 1) -> (next, 0) -> (StartReceiver, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Get, 0) -> (MatchString, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (Do, 1) -> (transformResponse, 2) -> (isTextResponse, 1)
(validateKafkaSecret, 1) -> (String, 2) -> (Equal, 2) -> (cachingEqual, 3) -> (Error, 0) -> (normalized, 0) -> (mergePaths, 2)
(validateKafkaSecret, 1) -> (String, 2) -> (AsStringSlice, 1) -> (Index, 1) -> (Get, 0) -> (MatchString, 1) -> (ReadFile, 1) -> (ReadObject, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Sign, 0) -> (UnscaledBig, 0) -> (Err, 0) -> (Proto, 0) -> (handleRawConn, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Close, 0) -> (Broadcast, 0) -> (conversionHandler, 3) -> (Convert, 2) -> (Build, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (open, 0) -> (newObject, 1) -> (toObjectACLRules, 1) -> (toObjectACLRule, 1) -> (poller, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (String, 0) -> (URL, 1) -> (parseText, 1) -> (next, 0) -> (SetupHelper, 4) -> (GetSlackChannels, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (write, 1) -> (put, 1) -> (executeAndPut, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Get, 0) -> (MatchString, 1) -> (ReadFile, 1) -> (ReadObject, 3)
(validateKafkaSecret, 1) -> (String, 2) -> (AsStringSlice, 1) -> (Index, 1) -> (PBValueOf, 1) -> (ValueOfMap, 1) -> (Observe, 1) -> (asyncFlush, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (FormatDiff, 2) -> (formatDiffList, 3) -> (CanInterface, 0) -> (fromString, 1) -> (Cleanup, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (open, 0) -> (newObject, 1) -> (toObjectACLRules, 1) -> (toObjectACLRule, 1) -> (RoundTrip, 1) -> (after, 3) -> (shouldEscape, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (ValueOf, 1) -> (valueOfIface, 1) -> (valueOfBytes, 1) -> (newValidationInfo, 2) -> (DispatchMessageWithRetries, 7) -> (executeRequest, 5) -> (PassThroughHeaders, 1) -> (CheckRetry, 1) -> (truncatingFormat, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (String, 0) -> (URL, 1) -> (parseText, 1) -> (next, 0) -> (consume, 2) -> (waitClosed, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (IsZero, 0) -> (Sign, 0) -> (IsNegative, 0) -> (Shutdown, 1) -> (HandleBenchmarkResult, 4) -> (CloseIssueForTest, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Start, 0) -> (start, 0) -> (UpdateState, 1) -> (updateResolverState, 2) -> (combineBodyMedia, 5) -> (newMultipartReader, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (IsZero, 0) -> (Sign, 0) -> (IsNegative, 0) -> (Shutdown, 1) -> (handleRawConn, 1) -> (removeConn, 1) -> (methodFamily, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (Reset, 1) -> (resetMessage, 1) -> (SetUnknown, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Write, 1) -> (printWithFileLine, 6) -> (output, 6) -> (timeoutFlush, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Write, 1) -> (printWithFileLine, 6) -> (output, 6) -> (timeoutFlush, 1) -> (connect, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Start, 0) -> (start, 0) -> (UpdateState, 1) -> (updateResolverState, 2) -> (Cleanup, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Error, 0) -> (normalized, 0) -> (mergePaths, 2) -> (containsString, 2) -> (DispatchMessageWithRetries, 7) -> (executeRequest, 5) -> (PassThroughHeaders, 1) -> (CheckRetry, 1) -> (truncatingFormat, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Decode, 1) -> (ParseUint, 3) -> (hasRecentError, 2) -> (newCountValue, 2) -> (handleSuccess, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Sign, 0) -> (UnscaledBig, 0) -> (Err, 0) -> (Proto, 0) -> (SetupHelper, 4) -> (GetSlackChannels, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (rotateFile, 1) -> (Version, 0) -> (Version, 1) -> (Flag, 2) -> (getLoggingConfig, 1) -> (ConfigToJSON, 1) -> (levelFromString, 1) -> (lex, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (prepareNext, 1) -> (append, 3) -> (BoolVar, 1) -> (typeName, 0) -> (RoundTrip, 1) -> (after, 3) -> (shouldEscape, 1) -> (legalHeaderByte, 1) -> (RelativizePathWithNoBacksteps, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (prepareNext, 1) -> (append, 3) -> (BoolVar, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (nextBlock, 1) -> (println, 1) -> (setPrev, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (Sub, 1) -> (AsDec, 0) -> (SetScale, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (open, 0) -> (newObject, 1) -> (toObjectACLRules, 1) -> (toObjectACLRule, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (Do, 1) -> (transformResponse, 2) -> (isTextResponse, 1) -> (NewGenericServerResponse, 7) -> (StartConsumerGroup, 4) -> (Consume, 3) -> (release, 1) -> (topicToPartitionNumbers, 1) -> (Partitions, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (prepareNext, 1) -> (append, 3) -> (BoolVar, 1) -> (typeName, 0) -> (RoundTrip, 1) -> (after, 3) -> (shouldEscape, 1) -> (legalHeaderByte, 1) -> (RelativizePathWithNoBacksteps, 2) -> (MakeRelative, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (FormatDiff, 2) -> (formatDiffList, 3) -> (CanInterface, 0) -> (fromString, 1) -> (DispatchMessageWithRetries, 7) -> (executeRequest, 5) -> (PassThroughHeaders, 1) -> (CheckRetry, 1) -> (truncatingFormat, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Load, 0) -> (UntypedLoad, 1) -> (DeepCopyObject, 0) -> (andTerm, 1) -> (sendAndReceiveKerberos, 0) -> (Authorize, 1) -> (readPackage, 1) -> (NewInitiatorWrapToken, 2) -> (SetCheckSum, 2)
(validateKafkaSecret, 1) -> (String, 2) -> (AsStringSlice, 1) -> (Index, 1) -> (Get, 0) -> (MatchString, 1) -> (ReadFile, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (FullPath, 0) -> (Free, 0) -> (unref, 0) -> (freeTrace, 1) -> (handleSuccess, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Sign, 0) -> (UnscaledBig, 0) -> (Err, 0) -> (Proto, 0) -> (PollUntil, 3) -> (WaitFor, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (prepareNext, 1) -> (append, 3) -> (BoolVar, 1) -> (typeName, 0) -> (handleRawConn, 1) -> (removeConn, 1) -> (methodFamily, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Len, 0) -> (Get, 0) -> (readFileFromKoData, 1) -> (hasInformer, 0) -> (RemoteCredProvider, 2) -> (ec2RoleProvider, 2) -> (EndpointFor, 2) -> (Of, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (Write, 1) -> (printWithFileLine, 6) -> (output, 6) -> (timeoutFlush, 1) -> (asyncFlush, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Flush, 0) -> (onFlush, 0) -> (recordDroppedTimeseries, 2) -> (isMyEvent, 1) -> (addEvent, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Decode, 1) -> (ParseUint, 3) -> (hasRecentError, 2) -> (newCountValue, 2) -> (waitClosed, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Sign, 0) -> (UnscaledBig, 0) -> (Err, 0) -> (Proto, 0) -> (handleRawConn, 1) -> (removeConn, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (Do, 1) -> (transformResponse, 2) -> (isTextResponse, 1) -> (NewGenericServerResponse, 7) -> (StartConsumerGroup, 4) -> (Consume, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (String, 0) -> (URL, 1) -> (parseText, 1) -> (next, 0) -> (GoPaths, 0) -> (Get, 2) -> (NewSharedIndexInformer, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Get, 0) -> (MatchString, 1) -> (ReadFile, 1) -> (ReadObject, 3) -> (ConfigureTransports, 1) -> (configureTransports, 1) -> (addConnIfNeeded, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (stringOff, 1) -> (WriteString, 1) -> (Get, 0) -> (MatchString, 1) -> (ReadFile, 1) -> (ReadObject, 3) -> (retryBatch, 4) -> (getBrokerProducer, 1) -> (newBrokerProducer, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (Append, 2) -> (FullName, 0) -> (formatDescOpt, 3) -> (Append, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (Close, 0) -> (Broadcast, 0) -> (conversionHandler, 3) -> (Convert, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (String, 0) -> (URL, 1) -> (parseText, 1) -> (next, 0) -> (handleSuccess, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (FormatDiff, 2) -> (formatDiffList, 3) -> (CanInterface, 0) -> (fromString, 1) -> (consume, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Start, 0) -> (start, 0) -> (UpdateState, 1) -> (updateResolverState, 2) -> (RoundTrip, 1) -> (after, 3) -> (shouldEscape, 1)
(validateKafkaSecret, 1) -> (String, 2) -> (AsStringSlice, 1) -> (Index, 1) -> (Get, 0) -> (MatchString, 1) -> (ReadFile, 1) -> (ReadObject, 3) -> (localHTTPCredProvider, 3) -> (Log, 3) -> (Of, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Sub, 1) -> (AsDec, 0) -> (SetScale, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Start, 0) -> (start, 0) -> (UpdateState, 1) -> (updateResolverState, 2) -> (Build, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Has, 1) -> (findJsonNameField, 1) -> (CanOmit, 1) -> (isZero, 1) -> (Cleanup, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Sign, 0) -> (UnscaledBig, 0) -> (Err, 0) -> (Proto, 0) -> (HandleBenchmarkResult, 4) -> (CloseIssueForTest, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (open, 0) -> (newObject, 1) -> (toObjectACLRules, 1) -> (toObjectACLRule, 1) -> (Build, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Write, 1) -> (printWithFileLine, 6) -> (output, 6) -> (timeoutFlush, 1) -> (combineBodyMedia, 5) -> (newMultipartReader, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Get, 0) -> (MatchString, 1) -> (ReadFile, 1) -> (ReadObject, 3) -> (combineBodyMedia, 5) -> (newMultipartReader, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Do, 1) -> (transformResponse, 2) -> (isTextResponse, 1) -> (NewGenericServerResponse, 7) -> (RoundTrip, 1) -> (after, 3) -> (shouldEscape, 1) -> (legalHeaderByte, 1) -> (GroupVersions, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Has, 1) -> (findJsonNameField, 1) -> (CanOmit, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Errorf, 2) -> (printf, 4) -> (output, 6) -> (timeoutFlush, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Write, 1) -> (printWithFileLine, 6) -> (output, 6) -> (timeoutFlush, 1) -> (handleSuccess, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Sign, 0) -> (UnscaledBig, 0) -> (Err, 0) -> (Proto, 0) -> (ExecutePace, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Error, 0) -> (normalized, 0) -> (mergePaths, 2) -> (containsString, 2) -> (DispatchMessageWithRetries, 7) -> (executeRequest, 5) -> (PassThroughHeaders, 1) -> (CheckRetry, 1) -> (truncatingFormat, 1) -> (detectRaces, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (New, 1) -> (HTTPWrappersForConfig, 2) -> (NewImpersonatingRoundTripper, 2) -> (Token, 0) -> (retryBatch, 4) -> (getBrokerProducer, 1) -> (newBrokerProducer, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Sign, 0) -> (UnscaledBig, 0) -> (Err, 0) -> (Proto, 0) -> (runConcurrent, 2) -> (runWithFriendlyError, 3) -> (run, 3) -> (runCmdContext, 2) -> (newClientConn, 2)
(validateKafkaSecret, 1) -> (String, 2) -> (Reset, 0) -> (make, 2) -> (WithConcurrency, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (String, 0) -> (URL, 1) -> (parseText, 1) -> (next, 0) -> (StartReceiver, 2) -> (Invoke, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Flush, 0) -> (onFlush, 0) -> (recordDroppedTimeseries, 2) -> (isMyEvent, 1) -> (LazyPrintf, 2) -> (addEvent, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Start, 0) -> (start, 0) -> (UpdateState, 1) -> (updateResolverState, 2) -> (retryBatch, 4) -> (getBrokerProducer, 1) -> (newBrokerProducer, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Load, 0) -> (UntypedLoad, 1) -> (DeepCopyObject, 0) -> (andTerm, 1) -> (sendAndReceiveKerberos, 0) -> (Authorize, 1) -> (readPackage, 1) -> (NewInitiatorWrapToken, 2) -> (SetCheckSum, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (writeAsCSV, 1) -> (TrimSuffix, 2) -> (onFlush, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (Do, 1) -> (transformResponse, 2) -> (isTextResponse, 1) -> (NewGenericServerResponse, 7)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Get, 0) -> (MatchString, 1) -> (ReadFile, 1) -> (ReadObject, 3) -> (ConfigureTransports, 1) -> (configureTransports, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Sign, 0) -> (UnscaledBig, 0) -> (Err, 0) -> (Proto, 0) -> (newHTTP2Transport, 2) -> (Warning, 4) -> (newHTTP2Server, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Get, 0) -> (MatchString, 1) -> (ReadFile, 1) -> (ReadObject, 3) -> (retryBatch, 4) -> (getBrokerProducer, 1) -> (newBrokerProducer, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (rotateFile, 1) -> (Version, 0) -> (Version, 1) -> (Flag, 2) -> (DispatchMessageWithRetries, 7) -> (executeRequest, 5) -> (PassThroughHeaders, 1) -> (CheckRetry, 1) -> (truncatingFormat, 1) -> (detectRaces, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (String, 0) -> (URL, 1) -> (parseText, 1) -> (next, 0) -> (newQueue, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Error, 0) -> (normalized, 0) -> (mergePaths, 2) -> (containsString, 2) -> (consume, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Parse, 1) -> (parseText, 1) -> (next, 0) -> (fill, 1) -> (connect, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (IsZero, 0) -> (Sign, 0) -> (IsNegative, 0) -> (Shutdown, 1) -> (StartReceiver, 2) -> (Invoke, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (nextBlock, 1) -> (println, 1) -> (setPrev, 3) -> (compareSwap, 3) -> (RoundTrip, 1) -> (after, 3) -> (shouldEscape, 1) -> (legalHeaderByte, 1) -> (GroupVersions, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (Reset, 1) -> (resetMessage, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Get, 0) -> (MatchString, 1) -> (ReadFile, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (FormatDiff, 2) -> (formatDiffList, 3) -> (CanInterface, 0) -> (fromString, 1) -> (StartConsumerGroup, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Sign, 0) -> (UnscaledBig, 0) -> (Err, 0) -> (Proto, 0) -> (handleRawConn, 1) -> (removeConn, 1) -> (methodFamily, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Get, 0) -> (MatchString, 1) -> (ReadFile, 1) -> (ReadObject, 3) -> (ConfigureTransports, 1) -> (configureTransports, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (New, 1) -> (HTTPWrappersForConfig, 2) -> (NewImpersonatingRoundTripper, 2) -> (Token, 0) -> (retryBatch, 4) -> (getBrokerProducer, 1) -> (newBrokerProducer, 1)
(validateKafkaSecret, 1) -> (String, 2) -> (Equal, 2) -> (cachingEqual, 3) -> (Get, 1) -> (GetUsing, 2) -> (allocValueUnstructured, 0) -> (allocate, 0) -> (ConfigureTransports, 1) -> (configureTransports, 1) -> (addConnIfNeeded, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (String, 0) -> (URL, 1) -> (parseText, 1) -> (next, 0) -> (consume, 2) -> (waitClosed, 0) -> (WithFinish, 2) -> (MarkOffset, 4) -> (MarkOffset, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Close, 0) -> (Broadcast, 0) -> (conversionHandler, 3) -> (Convert, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (nextBlock, 1) -> (println, 1) -> (setPrev, 3) -> (compareSwap, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (prepareNext, 1) -> (append, 3) -> (BoolVar, 1) -> (typeName, 0) -> (newQueue, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Sign, 0) -> (UnscaledBig, 0) -> (Err, 0) -> (Proto, 0) -> (maybeReportTransition, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Sign, 0) -> (UnscaledBig, 0) -> (Err, 0) -> (Proto, 0) -> (RunContext, 2) -> (processNextWorkItem, 0) -> (handleErr, 2) -> (ShuttingDown, 0) -> (AdmissionregistrationV1, 0)
(validateKafkaSecret, 1) -> (String, 2) -> (AsStringSlice, 1) -> (Index, 1) -> (lazyInit, 0) -> (lazyInitSlow, 0) -> (newValidationInfo, 2) -> (IsWeak, 0) -> (Equal, 3) -> (Equal, 4) -> (formatUnequalValues, 2) -> (truncatingFormat, 1) -> (SplitAfter, 2)
(validateKafkaSecret, 1) -> (String, 2) -> (Reset, 0) -> (make, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Start, 0) -> (start, 0) -> (UpdateState, 1) -> (updateResolverState, 2) -> (on100, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (write, 3) -> (width, 1) -> (yaml_emitter_set_writer_error, 2) -> (NewImpersonatingRoundTripper, 2) -> (handleSuccess, 2) -> (dropPartition, 2) -> (getBrokerProducer, 1) -> (newBrokerProducer, 1)
(validateKafkaSecret, 1) -> (String, 2) -> (Reset, 0) -> (make, 2) -> (init, 0) -> (UTC, 0) -> (setCurMetricsConfig, 1) -> (setCurMetricsConfigUnlocked, 1) -> (runConcurrent, 2) -> (runWithFriendlyError, 3) -> (run, 3) -> (runCmdContext, 2) -> (newClientConn, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (IsZero, 0) -> (Sign, 0) -> (IsNegative, 0) -> (Shutdown, 1) -> (Watch, 1) -> (WatchFunc, 1)
(validateKafkaSecret, 1) -> (String, 2) -> (Reset, 0) -> (make, 2) -> (, 0) -> (NewStream, 3) -> (Store, 1) -> (packError, 1) -> (serveStreams, 1) -> (methodFamily, 1)
(validateKafkaSecret, 1) -> (String, 2) -> (AsStringSlice, 1) -> (Index, 1) -> (Get, 0) -> (MatchString, 1) -> (ReadFile, 1) -> (ReadObject, 3) -> (retryBatch, 4) -> (getBrokerProducer, 1) -> (newBrokerProducer, 1)
(validateKafkaSecret, 1) -> (String, 2) -> (Equal, 2) -> (cachingEqual, 3) -> (Range, 1) -> (extensionMap, 1) -> (handleResponse, 1) -> (handleSuccess, 2) -> (retryBatch, 4) -> (getBrokerProducer, 1) -> (newBrokerProducer, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (String, 0) -> (URL, 1) -> (parseText, 1) -> (next, 0) -> (processResult, 2) -> (openBreaker, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Decode, 1) -> (ParseUint, 3) -> (hasRecentError, 2) -> (newCountValue, 2) -> (ConfigureTransport, 1) -> (ConfigureTransports, 1) -> (configureTransports, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (New, 1) -> (HTTPWrappersForConfig, 2) -> (NewImpersonatingRoundTripper, 2) -> (Token, 0) -> (ConfigureTransports, 1) -> (configureTransports, 1) -> (addConnIfNeeded, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (Get, 0) -> (MatchString, 1) -> (ReadFile, 1) -> (ReadObject, 3) -> (retryBatch, 4) -> (getBrokerProducer, 1) -> (newBrokerProducer, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (String, 0) -> (URL, 1) -> (parseText, 1) -> (next, 0)
(validateKafkaSecret, 1) -> (String, 2) -> (Reset, 0) -> (make, 2) -> (Add, 1) -> (insert, 1) -> (evict, 0) -> (evictOldest, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Close, 0) -> (Broadcast, 0) -> (conversionHandler, 3) -> (Convert, 2) -> (StartConsumerGroup, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (open, 0) -> (newObject, 1) -> (toObjectACLRules, 1) -> (toObjectACLRule, 1) -> (addEvent, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (stringOff, 1) -> (WriteString, 1) -> (Get, 0) -> (MatchString, 1) -> (ReadFile, 1) -> (ReadObject, 3) -> (localHTTPCredProvider, 3) -> (Log, 3) -> (Of, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Do, 1) -> (transformResponse, 2) -> (isTextResponse, 1) -> (NewGenericServerResponse, 7) -> (StartConsumerGroup, 4) -> (Consume, 3) -> (release, 1) -> (topicToPartitionNumbers, 1) -> (Partitions, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Sign, 0) -> (UnscaledBig, 0) -> (Err, 0) -> (Proto, 0) -> (handleRawConn, 1) -> (removeConn, 1) -> (methodFamily, 1) -> (processStreamingRPC, 5)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (write, 3) -> (width, 1) -> (yaml_emitter_set_writer_error, 2) -> (NewImpersonatingRoundTripper, 2) -> (connect, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Get, 0) -> (MatchString, 1) -> (ReadFile, 1) -> (ReadObject, 3) -> (executeCredentialProcess, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (open, 0) -> (newObject, 1) -> (toObjectACLRules, 1) -> (toObjectACLRule, 1) -> (newAsyncProducer, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (Do, 1) -> (transformResponse, 2) -> (isTextResponse, 1) -> (NewGenericServerResponse, 7) -> (StartConsumerGroup, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (write, 3) -> (width, 1) -> (yaml_emitter_set_writer_error, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (nextBlock, 1) -> (println, 1) -> (setPrev, 3) -> (compareSwap, 3) -> (poller, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (String, 0) -> (URL, 1) -> (parseText, 1) -> (next, 0) -> (HandleBenchmarkResult, 4) -> (CloseIssueForTest, 1)
(validateKafkaSecret, 1) -> (String, 2) -> (Reset, 0) -> (make, 2) -> (init, 0) -> (UTC, 0) -> (setCurMetricsConfig, 1) -> (setCurMetricsConfigUnlocked, 1) -> (processNextWorkItem, 0) -> (handleErr, 2) -> (ShuttingDown, 0) -> (AdmissionregistrationV1, 0) -> (newValidatingWebhookConfigurations, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Value, 0) -> (ScaledValue, 1) -> (infScale, 0) -> (DivMod, 3) -> (getLoggingConfig, 1) -> (ConfigToJSON, 1) -> (levelFromString, 1) -> (lex, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (IsZero, 0) -> (Sign, 0) -> (IsNegative, 0) -> (Shutdown, 1) -> (RunRaw, 2) -> (runPiped, 4) -> (runWithFriendlyError, 3) -> (run, 3) -> (runCmdContext, 2) -> (newClientConn, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Reset, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (FullPath, 0) -> (Free, 0) -> (unref, 0) -> (freeTrace, 1) -> (asyncFlush, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (open, 0) -> (newObject, 1) -> (toObjectACLRules, 1) -> (toObjectACLRule, 1) -> (StartConsumerGroup, 4) -> (Consume, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (New, 1) -> (HTTPWrappersForConfig, 2) -> (NewImpersonatingRoundTripper, 2) -> (Token, 0) -> (NewNamedDelayingQueue, 1) -> (NewDelayingQueueWithCustomClock, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (String, 0) -> (URL, 1) -> (parseText, 1) -> (next, 0) -> (poll, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Error, 0) -> (normalized, 0) -> (mergePaths, 2) -> (containsString, 2) -> (handleSuccess, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (Write, 1) -> (printWithFileLine, 6) -> (output, 6) -> (timeoutFlush, 1) -> (LazyLog, 2) -> (addEvent, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Bytes, 0) -> (BytesVar, 1) -> (newBytesValue, 1) -> (remaining, 0) -> (consume, 2) -> (waitClosed, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Reset, 1) -> (resetMessage, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Load, 0) -> (UntypedLoad, 1) -> (DeepCopyObject, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Validate, 0) -> (New, 1) -> (HTTPWrappersForConfig, 2) -> (NewImpersonatingRoundTripper, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (Has, 1) -> (findJsonNameField, 1) -> (CanOmit, 1) -> (isZero, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Sign, 0) -> (UnscaledBig, 0) -> (Err, 0) -> (Proto, 0) -> (reportCount, 3) -> (ReportCRStatusEvent, 2) -> (createEvent, 2) -> (getRecorder, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (New, 1) -> (HTTPWrappersForConfig, 2) -> (NewImpersonatingRoundTripper, 2) -> (Token, 0) -> (sendAndReceiveKerberos, 0) -> (Authorize, 1) -> (readPackage, 1) -> (NewInitiatorWrapToken, 2) -> (SetCheckSum, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (open, 0) -> (newObject, 1) -> (toObjectACLRules, 1) -> (toObjectACLRule, 1) -> (DispatchMessageWithRetries, 7) -> (executeRequest, 5) -> (PassThroughHeaders, 1) -> (CheckRetry, 1) -> (truncatingFormat, 1) -> (detectRaces, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Parse, 1) -> (parseText, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (MarshalText, 0) -> (Level, 0) -> (int8, 1) -> (loggerOptionFunc, 1) -> (newQueue, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (open, 0) -> (newObject, 1) -> (toObjectACLRules, 1) -> (toObjectACLRule, 1) -> (Build, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Error, 0) -> (normalized, 0) -> (mergePaths, 2) -> (containsString, 2) -> (RemoteCredProvider, 2) -> (ec2RoleProvider, 2) -> (EndpointFor, 2) -> (Of, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (prepareNext, 1) -> (append, 3) -> (BoolVar, 1) -> (typeName, 0) -> (getContext, 0) -> (NewContext, 0) -> (SetupSignalHandler, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Start, 0) -> (start, 0) -> (UpdateState, 1) -> (updateResolverState, 2) -> (updateClientConnState, 1) -> (UpdateClientConnState, 1) -> (UpdateAddresses, 1) -> (newAddrConn, 2) -> (RegisterSubChannel, 3) -> (addSubChannel, 4) -> (GetFallbackResponse, 0) -> (newClientStream, 5)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (nextBlock, 1) -> (println, 1) -> (setPrev, 3) -> (compareSwap, 3) -> (Build, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (Write, 1) -> (printWithFileLine, 6) -> (output, 6) -> (timeoutFlush, 1) -> (LazyPrintf, 2) -> (addEvent, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (FormatDiff, 2) -> (formatDiffList, 3) -> (CanInterface, 0) -> (fromString, 1) -> (handleRawConn, 1) -> (removeConn, 1)
(validateKafkaSecret, 1) -> (String, 2) -> (Reset, 0) -> (make, 2) -> (init, 0) -> (UTC, 0) -> (setCurMetricsConfig, 1) -> (setCurMetricsConfigUnlocked, 1) -> (updateClientConnState, 1) -> (UpdateClientConnState, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Decode, 1) -> (ParseUint, 3) -> (hasRecentError, 2) -> (newCountValue, 2) -> (newConsumerGroupClaim, 4) -> (ConsumePartition, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (String, 0) -> (URL, 1) -> (parseText, 1) -> (next, 0) -> (getContext, 0) -> (NewContext, 0) -> (SetupSignalHandler, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Has, 1) -> (findJsonNameField, 1) -> (CanOmit, 1) -> (isZero, 1) -> (getLoggingConfig, 1) -> (ConfigToJSON, 1) -> (levelFromString, 1) -> (lex, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (New, 1) -> (HTTPWrappersForConfig, 2)
(validateKafkaSecret, 1) -> (String, 2) -> (Reset, 0) -> (make, 2) -> (init, 0) -> (UTC, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (open, 0) -> (newObject, 1) -> (toObjectACLRules, 1) -> (toObjectACLRule, 1) -> (StartConsumerGroup, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (open, 0) -> (newObject, 1) -> (toObjectACLRules, 1) -> (toObjectACLRule, 1) -> (newAsyncProducer, 1)
(validateKafkaSecret, 1) -> (String, 2) -> (Reset, 0) -> (make, 2) -> (New, 1) -> (HTTPWrappersForConfig, 2) -> (NewImpersonatingRoundTripper, 2) -> (Token, 0) -> (retryBatch, 4) -> (getBrokerProducer, 1) -> (newBrokerProducer, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (FormatDiff, 2) -> (formatDiffList, 3) -> (CanInterface, 0) -> (fromString, 1) -> (StartConsumerGroup, 4) -> (Consume, 3) -> (release, 1) -> (topicToPartitionNumbers, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (open, 0) -> (newObject, 1) -> (toObjectACLRules, 1) -> (toObjectACLRule, 1) -> (StartConsumerGroup, 4) -> (Consume, 3) -> (release, 1) -> (topicToPartitionNumbers, 1) -> (Partitions, 1)
(validateKafkaSecret, 1) -> (String, 2) -> (Reset, 0) -> (make, 2) -> (init, 0) -> (UTC, 0) -> (setCurMetricsConfig, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (prepareNext, 1) -> (append, 3) -> (BoolVar, 1) -> (typeName, 0) -> (StartConsumerGroup, 4)
(validateKafkaSecret, 1) -> (String, 2) -> (Reset, 0) -> (make, 2) -> (New, 1) -> (HTTPWrappersForConfig, 2) -> (NewImpersonatingRoundTripper, 2) -> (Token, 0) -> (NewNamedDelayingQueue, 1) -> (NewDelayingQueueWithCustomClock, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (prepareNext, 1) -> (append, 3) -> (BoolVar, 1) -> (typeName, 0) -> (RoundTrip, 1) -> (after, 3) -> (shouldEscape, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (FullPath, 0) -> (Free, 0) -> (unref, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (Close, 0) -> (Broadcast, 0) -> (conversionHandler, 3) -> (Convert, 2) -> (startFrameWrite, 1)
(validateKafkaSecret, 1) -> (String, 2) -> (AsStringSlice, 1) -> (Index, 1) -> (lazyInit, 0) -> (lazyInitSlow, 0) -> (newValidationInfo, 2) -> (IsWeak, 0) -> (Equal, 3) -> (Equal, 4) -> (formatUnequalValues, 2) -> (truncatingFormat, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (nextBlock, 1) -> (println, 1) -> (setPrev, 3) -> (compareSwap, 3) -> (sendAndReceiveKerberos, 0) -> (Authorize, 1) -> (readPackage, 1) -> (NewInitiatorWrapToken, 2) -> (SetCheckSum, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Write, 1) -> (printWithFileLine, 6) -> (output, 6) -> (timeoutFlush, 1) -> (NewEventListener, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Close, 0) -> (Broadcast, 0) -> (conversionHandler, 3) -> (Convert, 2) -> (combineBodyMedia, 5) -> (newMultipartReader, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Close, 0) -> (Broadcast, 0) -> (conversionHandler, 3) -> (Convert, 2) -> (StartConsumerGroup, 4) -> (Consume, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Get, 0) -> (MatchString, 1) -> (ReadFile, 1) -> (ReadObject, 3) -> (ConfigureTransports, 1) -> (configureTransports, 1) -> (addConnIfNeeded, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (FormatDiff, 2) -> (formatDiffList, 3) -> (CanInterface, 0) -> (fromString, 1) -> (consume, 2) -> (waitClosed, 0) -> (WithFinish, 2) -> (MarkOffset, 4) -> (MarkOffset, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (Close, 0) -> (Broadcast, 0) -> (conversionHandler, 3) -> (Convert, 2) -> (RoundTrip, 1) -> (after, 3) -> (shouldEscape, 1) -> (legalHeaderByte, 1) -> (GroupVersions, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (Write, 1) -> (printWithFileLine, 6) -> (output, 6) -> (timeoutFlush, 1) -> (DispatchMessageWithRetries, 7) -> (executeRequest, 5) -> (PassThroughHeaders, 1) -> (CheckRetry, 1) -> (truncatingFormat, 1) -> (SplitAfter, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Decode, 1) -> (ParseUint, 3) -> (hasRecentError, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Sign, 0) -> (UnscaledBig, 0) -> (Err, 0) -> (Proto, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Write, 1) -> (printWithFileLine, 6) -> (output, 6) -> (timeoutFlush, 1) -> (asyncFlush, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (compressBlock, 1) -> (, 0) -> (NewStream, 3) -> (DurationP, 4) -> (poller, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (IsZero, 0) -> (Sign, 0) -> (IsNegative, 0) -> (Shutdown, 1) -> (Send, 2) -> (reportCount, 3) -> (ReportCRStatusEvent, 2) -> (createEvent, 2) -> (getRecorder, 4) -> (NewRecorder, 2) -> (recordToSink, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (stringOff, 1) -> (WriteString, 1) -> (prepareNext, 1) -> (, 0) -> (NewStream, 3) -> (DurationP, 4) -> (newAsyncProducer, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (Get, 0) -> (MatchString, 1) -> (ReadFile, 1) -> (ReadObject, 3) -> (NewNamedDelayingQueue, 1) -> (NewDelayingQueueWithCustomClock, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (FormatDiff, 2) -> (formatDiffList, 3) -> (CanInterface, 0) -> (fromString, 1) -> (handleRawConn, 1) -> (removeConn, 1) -> (methodFamily, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Has, 1) -> (findJsonNameField, 1) -> (CanOmit, 1) -> (isZero, 1) -> (DispatchMessageWithRetries, 7) -> (executeRequest, 5) -> (PassThroughHeaders, 1) -> (CheckRetry, 1) -> (truncatingFormat, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (String, 0) -> (URL, 1) -> (parseText, 1) -> (next, 0) -> (asyncFlush, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Sign, 0) -> (UnscaledBig, 0) -> (Err, 0) -> (Proto, 0) -> (StartReceiver, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (compressBlock, 1) -> (, 0) -> (NewStream, 3) -> (DurationP, 4) -> (Build, 3)
(validateKafkaSecret, 1) -> (String, 2) -> (Reset, 0) -> (make, 2) -> (, 0) -> (NewStream, 3) -> (Store, 1) -> (packError, 1) -> (newHTTP2Transport, 2) -> (Warning, 4) -> (newHTTP2Server, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (String, 0) -> (URL, 1) -> (parseText, 1) -> (next, 0) -> (consume, 2) -> (waitClosed, 0) -> (WithFinish, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Start, 0) -> (start, 0) -> (UpdateState, 1) -> (updateResolverState, 2) -> (createTransport, 3) -> (NewClientTransport, 7) -> (newHTTP2Client, 7)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (compressBlock, 1) -> (, 0) -> (NewStream, 3) -> (DurationP, 4) -> (StartConsumerGroup, 4) -> (Consume, 3) -> (release, 1) -> (topicToPartitionNumbers, 1) -> (Partitions, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Encode, 2) -> (SetGroupVersionKind, 1) -> (SetKind, 1) -> (setNestedField, 2) -> (poller, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Error, 0) -> (normalized, 0) -> (mergePaths, 2) -> (containsString, 2) -> (asyncFlush, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (nextBlock, 1) -> (println, 1) -> (setPrev, 3) -> (compareSwap, 3) -> (poller, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (Get, 0) -> (MatchString, 1) -> (ReadFile, 1) -> (ReadObject, 3) -> (ConfigureTransports, 1) -> (configureTransports, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (MarshalText, 0) -> (Level, 0) -> (int8, 1) -> (loggerOptionFunc, 1) -> (Get, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Sign, 0) -> (UnscaledBig, 0) -> (Err, 0) -> (Proto, 0) -> (processResult, 2) -> (openBreaker, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (String, 0) -> (URL, 1) -> (parseText, 1) -> (next, 0) -> (List, 1) -> (ListFunc, 1) -> (WithPath, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Error, 0) -> (normalized, 0) -> (mergePaths, 2) -> (containsString, 2) -> (NewNamedRateLimitingQueue, 2) -> (NewNamedDelayingQueue, 1) -> (NewDelayingQueueWithCustomClock, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Close, 0) -> (Broadcast, 0) -> (conversionHandler, 3) -> (Convert, 2) -> (StartConsumerGroup, 4) -> (Consume, 3) -> (release, 1) -> (topicToPartitionNumbers, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (Reset, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (FormatDiff, 2) -> (formatDiffList, 3) -> (CanInterface, 0) -> (fromString, 1) -> (Build, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Get, 0) -> (MatchString, 1) -> (ReadFile, 1) -> (ReadObject, 3) -> (NewNamedDelayingQueue, 1) -> (NewDelayingQueueWithCustomClock, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Get, 0) -> (MatchString, 1) -> (ReadFile, 1) -> (ReadObject, 3) -> (NewNamedDelayingQueue, 1) -> (NewDelayingQueueWithCustomClock, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Do, 1) -> (transformResponse, 2) -> (isTextResponse, 1) -> (NewGenericServerResponse, 7) -> (StartConsumerGroup, 4) -> (Consume, 3) -> (release, 1) -> (topicToPartitionNumbers, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (compressBlock, 1) -> (, 0) -> (NewStream, 3) -> (DurationP, 4) -> (sendAndReceiveKerberos, 0) -> (Authorize, 1) -> (readPackage, 1) -> (NewInitiatorWrapToken, 2) -> (SetCheckSum, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (open, 0) -> (newObject, 1) -> (toObjectACLRules, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (swapBufs, 1) -> (Add, 1) -> (PushFunc, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (String, 0) -> (URL, 1) -> (parseText, 1) -> (next, 0) -> (maybeReportTransition, 0)
(validateKafkaSecret, 1) -> (String, 2) -> (Reset, 0) -> (make, 2) -> (, 0) -> (NewStream, 3) -> (Store, 1) -> (packError, 1) -> (serveStreams, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Close, 0) -> (Broadcast, 0) -> (conversionHandler, 3) -> (Convert, 2) -> (Equal, 3) -> (Equal, 4) -> (formatUnequalValues, 2) -> (truncatingFormat, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (String, 0) -> (URL, 1) -> (parseText, 1) -> (next, 0) -> (RunRaw, 2) -> (runPiped, 4) -> (runWithFriendlyError, 3) -> (run, 3) -> (runCmdContext, 2) -> (newClientConn, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Value, 0) -> (ScaledValue, 1) -> (infScale, 0) -> (DivMod, 3) -> (DispatchMessageWithRetries, 7) -> (executeRequest, 5) -> (PassThroughHeaders, 1) -> (CheckRetry, 1) -> (truncatingFormat, 1) -> (detectRaces, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (Write, 1) -> (printWithFileLine, 6) -> (output, 6)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Bytes, 0) -> (BytesVar, 1) -> (newBytesValue, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (nextBlock, 1) -> (println, 1) -> (setPrev, 3) -> (compareSwap, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (Do, 1) -> (transformResponse, 2) -> (isTextResponse, 1) -> (NewGenericServerResponse, 7) -> (newAsyncProducer, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (prepareNext, 1) -> (append, 3) -> (BoolVar, 1) -> (typeName, 0) -> (Cleanup, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (String, 0) -> (URL, 1) -> (parseText, 1) -> (next, 0) -> (NewNamedRateLimitingQueue, 2) -> (NewNamedDelayingQueue, 1) -> (NewDelayingQueueWithCustomClock, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (Load, 0) -> (UntypedLoad, 1) -> (DeepCopyObject, 0) -> (andTerm, 1) -> (sendAndReceiveKerberos, 0) -> (Authorize, 1) -> (readPackage, 1) -> (NewInitiatorWrapToken, 2) -> (SetCheckSum, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Do, 1) -> (transformResponse, 2) -> (isTextResponse, 1) -> (NewGenericServerResponse, 7) -> (RoundTrip, 1) -> (after, 3) -> (shouldEscape, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (Close, 0) -> (Broadcast, 0) -> (conversionHandler, 3) -> (Convert, 2) -> (NewConfigFromMap, 1) -> (levelFromString, 1) -> (lex, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (String, 0) -> (URL, 1) -> (parseText, 1) -> (next, 0) -> (tryAllAddrs, 2) -> (updateConnectionError, 1) -> (NewClientTransport, 7) -> (newHTTP2Client, 7) -> (newLoopyWriter, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (IsZero, 0) -> (Sign, 0) -> (IsNegative, 0) -> (Shutdown, 1) -> (Send, 2) -> (reportCount, 3) -> (ReportCRStatusEvent, 2) -> (createEvent, 2) -> (getRecorder, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (write, 3) -> (width, 1) -> (yaml_emitter_set_writer_error, 2) -> (NewImpersonatingRoundTripper, 2) -> (handleSuccess, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (Close, 0) -> (Broadcast, 0) -> (conversionHandler, 3) -> (Convert, 2) -> (poller, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (String, 0) -> (URL, 1) -> (parseText, 1) -> (next, 0) -> (GoPaths, 0) -> (Get, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (prepareNext, 1) -> (append, 3) -> (BoolVar, 1) -> (typeName, 0) -> (List, 1) -> (ListFunc, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (FormatDiff, 2) -> (formatDiffList, 3) -> (CanInterface, 0) -> (fromString, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Sign, 0) -> (UnscaledBig, 0) -> (Err, 0) -> (Proto, 0) -> (StartInformers, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (compressBlock, 1) -> (, 0) -> (NewStream, 3) -> (DurationP, 4) -> (RoundTrip, 1) -> (after, 3) -> (shouldEscape, 1)
(validateKafkaSecret, 1) -> (String, 2) -> (AsStringSlice, 1) -> (Index, 1) -> (Get, 0) -> (MatchString, 1) -> (ReadFile, 1) -> (ReadObject, 3) -> (ConfigureTransports, 1) -> (configureTransports, 1) -> (addConnIfNeeded, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Error, 0) -> (normalized, 0) -> (mergePaths, 2) -> (containsString, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (New, 1) -> (HTTPWrappersForConfig, 2) -> (NewImpersonatingRoundTripper, 2) -> (Token, 0) -> (ConfigureTransports, 1) -> (configureTransports, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (New, 1) -> (HTTPWrappersForConfig, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Start, 0) -> (start, 0) -> (UpdateState, 1) -> (updateResolverState, 2) -> (RoundTrip, 1) -> (after, 3) -> (shouldEscape, 1) -> (legalHeaderByte, 1) -> (RelativizePathWithNoBacksteps, 2)
(validateKafkaSecret, 1) -> (String, 2) -> (Equal, 2) -> (cachingEqual, 3) -> (Get, 1) -> (GetUsing, 2) -> (allocValueUnstructured, 0) -> (allocate, 0) -> (reportCount, 3) -> (ReportCRStatusEvent, 2) -> (createEvent, 2) -> (getRecorder, 4) -> (NewRecorder, 2) -> (recordToSink, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (open, 0) -> (newObject, 1) -> (toObjectACLRules, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (rotateFile, 1) -> (Version, 0) -> (Version, 1) -> (Flag, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (stringOff, 1) -> (WriteString, 1) -> (prepareNext, 1) -> (, 0) -> (NewStream, 3) -> (DurationP, 4)
(validateKafkaSecret, 1) -> (String, 2) -> (Reset, 0) -> (make, 2) -> (New, 1) -> (HTTPWrappersForConfig, 2) -> (NewImpersonatingRoundTripper, 2) -> (Token, 0) -> (ConfigureTransports, 1) -> (configureTransports, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (IsZero, 0) -> (Sign, 0) -> (IsNegative, 0) -> (Shutdown, 1) -> (processResult, 2) -> (openBreaker, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Close, 0) -> (Broadcast, 0) -> (conversionHandler, 3) -> (Convert, 2) -> (sendAndReceiveKerberos, 0) -> (Authorize, 1) -> (readPackage, 1) -> (NewInitiatorWrapToken, 2) -> (SetCheckSum, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (nextBlock, 1) -> (println, 1) -> (setPrev, 3) -> (compareSwap, 3) -> (DispatchMessageWithRetries, 7) -> (executeRequest, 5) -> (PassThroughHeaders, 1) -> (CheckRetry, 1) -> (truncatingFormat, 1) -> (detectRaces, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (Close, 0) -> (Broadcast, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (rotateFile, 1) -> (Version, 0) -> (Version, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (printWithFileLine, 6) -> (output, 6) -> (timeoutFlush, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (EscapeValue, 1) -> (Replace, 1) -> (Set, 1) -> (Observe, 1) -> (asyncFlush, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (MarshalText, 0) -> (Level, 0) -> (int8, 1) -> (loggerOptionFunc, 1) -> (ConfigureTransport, 1) -> (ConfigureTransports, 1) -> (configureTransports, 1) -> (addConnIfNeeded, 3)
(validateKafkaSecret, 1) -> (String, 2) -> (Equal, 2) -> (cachingEqual, 3) -> (PBValueOf, 1) -> (ValueOfMap, 1) -> (Observe, 1) -> (asyncFlush, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Validate, 0) -> (New, 1) -> (HTTPWrappersForConfig, 2) -> (NewImpersonatingRoundTripper, 2) -> (handleSuccess, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Sign, 0) -> (UnscaledBig, 0) -> (Err, 0) -> (Proto, 0) -> (NewStreamWatcher, 2)
(validateKafkaSecret, 1) -> (String, 2) -> (Reset, 0) -> (make, 2) -> (Reset, 1) -> (resetMessage, 1) -> (SetUnknown, 1) -> (setUnknown, 2) -> (startFrameWrite, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (FullPath, 0) -> (Free, 0) -> (unref, 0) -> (freeTrace, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (Get, 0) -> (MatchString, 1) -> (ReadFile, 1) -> (ReadObject, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (prepareNext, 1) -> (append, 3) -> (BoolVar, 1) -> (typeName, 0) -> (newAsyncProducer, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (Close, 0) -> (Broadcast, 0) -> (conversionHandler, 3) -> (Convert, 2) -> (Build, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Now, 0) -> (Add, 1) -> (add, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Encode, 2) -> (SetGroupVersionKind, 1) -> (SetKind, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (New, 1) -> (HTTPWrappersForConfig, 2) -> (NewImpersonatingRoundTripper, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (Close, 0) -> (Broadcast, 0) -> (conversionHandler, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Sign, 0) -> (UnscaledBig, 0) -> (Err, 0) -> (Proto, 0) -> (RunRaw, 2) -> (runPiped, 4) -> (runWithFriendlyError, 3) -> (run, 3) -> (runCmdContext, 2) -> (newClientConn, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (nextBlock, 1) -> (println, 1) -> (setPrev, 3) -> (compareSwap, 3) -> (StartConsumerGroup, 4) -> (Consume, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Start, 0) -> (start, 0) -> (UpdateState, 1) -> (updateResolverState, 2) -> (StartConsumerGroup, 4) -> (Consume, 3) -> (release, 1) -> (topicToPartitionNumbers, 1) -> (Partitions, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (open, 0) -> (newObject, 1) -> (toObjectACLRules, 1) -> (toObjectACLRule, 1) -> (RoundTrip, 1) -> (after, 3) -> (shouldEscape, 1) -> (legalHeaderByte, 1) -> (RelativizePathWithNoBacksteps, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (Load, 0) -> (UntypedLoad, 1) -> (DeepCopyObject, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (IsZero, 0) -> (Sign, 0) -> (IsNegative, 0) -> (Shutdown, 1) -> (Attack, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Start, 0) -> (start, 0) -> (UpdateState, 1) -> (updateResolverState, 2) -> (newQueue, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (New, 1) -> (HTTPWrappersForConfig, 2) -> (NewImpersonatingRoundTripper, 2) -> (Token, 0) -> (startFrameWrite, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (Close, 0) -> (Broadcast, 0) -> (conversionHandler, 3) -> (Convert, 2) -> (newAsyncProducer, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Start, 0) -> (start, 0) -> (UpdateState, 1) -> (updateResolverState, 2) -> (NewNamedRateLimitingQueue, 2) -> (NewNamedDelayingQueue, 1) -> (NewDelayingQueueWithCustomClock, 2)
(validateKafkaSecret, 1) -> (String, 2) -> (Equal, 2) -> (cachingEqual, 3) -> (lazyInit, 0) -> (lazyInitSlow, 0) -> (newValidationInfo, 2) -> (IsWeak, 0) -> (NewConfigFromMap, 1) -> (levelFromString, 1) -> (lex, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (Write, 1) -> (printWithFileLine, 6) -> (output, 6) -> (timeoutFlush, 1) -> (DispatchMessageWithRetries, 7) -> (executeRequest, 5) -> (PassThroughHeaders, 1) -> (CheckRetry, 1) -> (truncatingFormat, 1)
(validateKafkaSecret, 1) -> (String, 2) -> (Equal, 2) -> (cachingEqual, 3) -> (Get, 1) -> (GetUsing, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Now, 0) -> (Add, 1) -> (insert, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Start, 0) -> (start, 0) -> (UpdateState, 1)
(validateKafkaSecret, 1) -> (String, 2) -> (Reset, 0) -> (make, 2) -> (init, 0) -> (UTC, 0) -> (setCurMetricsConfig, 1) -> (setCurMetricsConfigUnlocked, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (String, 0) -> (URL, 1) -> (parseText, 1) -> (next, 0) -> (RunContext, 2) -> (processNextWorkItem, 0) -> (handleErr, 2) -> (ShuttingDown, 0) -> (AdmissionregistrationV1, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (prepareNext, 1) -> (append, 3) -> (BoolVar, 1) -> (typeName, 0) -> (StartConsumerGroup, 4) -> (Consume, 3) -> (release, 1) -> (topicToPartitionNumbers, 1) -> (Partitions, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (stringOff, 1) -> (WriteString, 1) -> (Get, 0) -> (MatchString, 1) -> (ReadFile, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (MarshalText, 0) -> (Level, 0) -> (int8, 1) -> (loggerOptionFunc, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Start, 0) -> (start, 0) -> (UpdateState, 1) -> (updateResolverState, 2) -> (startFrameWrite, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (nextBlock, 1) -> (println, 1) -> (setPrev, 3) -> (compareSwap, 3) -> (newAsyncProducer, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (nextBlock, 1) -> (println, 1) -> (setPrev, 3) -> (compareSwap, 3) -> (RoundTrip, 1) -> (after, 3) -> (shouldEscape, 1) -> (legalHeaderByte, 1) -> (GroupVersions, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (open, 0) -> (newObject, 1) -> (toObjectACLRules, 1) -> (toObjectACLRule, 1) -> (RoundTrip, 1) -> (after, 3) -> (shouldEscape, 1) -> (legalHeaderByte, 1) -> (GroupVersions, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (IsZero, 0) -> (Sign, 0) -> (IsNegative, 0) -> (Shutdown, 1) -> (RunContext, 2) -> (processNextWorkItem, 0) -> (handleErr, 2) -> (ShuttingDown, 0) -> (AdmissionregistrationV1, 0) -> (newValidatingWebhookConfigurations, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (stringOff, 1) -> (WriteString, 1) -> (Get, 0) -> (MatchString, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (Get, 0) -> (MatchString, 1) -> (ReadFile, 1) -> (ReadObject, 3) -> (startFrameWrite, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Encode, 2) -> (SetGroupVersionKind, 1) -> (SetKind, 1) -> (setNestedField, 2) -> (List, 1) -> (ListFunc, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Write, 1) -> (printWithFileLine, 6) -> (output, 6) -> (timeoutFlush, 1) -> (ConfigureTransport, 1) -> (ConfigureTransports, 1) -> (configureTransports, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (Do, 1) -> (transformResponse, 2) -> (isTextResponse, 1) -> (NewGenericServerResponse, 7) -> (poller, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Sign, 0) -> (UnscaledBig, 0) -> (Err, 0) -> (Proto, 0) -> (runPiped, 4) -> (runWithFriendlyError, 3) -> (run, 3) -> (runCmdContext, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (compressBlock, 1) -> (, 0) -> (NewStream, 3) -> (DurationP, 4) -> (RoundTrip, 1) -> (after, 3) -> (shouldEscape, 1) -> (legalHeaderByte, 1) -> (GroupVersions, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (Do, 1) -> (transformResponse, 2) -> (isTextResponse, 1) -> (NewGenericServerResponse, 7) -> (sendAndReceiveKerberos, 0) -> (Authorize, 1) -> (readPackage, 1) -> (NewInitiatorWrapToken, 2) -> (SetCheckSum, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Load, 0) -> (UntypedLoad, 1) -> (DeepCopyObject, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (withDeadline, 2) -> (WithDeadline, 2) -> (AfterFunc, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Write, 1) -> (printWithFileLine, 6) -> (output, 6) -> (timeoutFlush, 1) -> (Cleanup, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Start, 0) -> (start, 0) -> (UpdateState, 1) -> (updateResolverState, 2) -> (handleSuccess, 2)
(validateKafkaSecret, 1) -> (String, 2) -> (Reset, 0) -> (make, 2) -> (, 0) -> (NewStream, 3) -> (Store, 1) -> (packError, 1) -> (RoundTripOpt, 2) -> (shouldRetryRequest, 3) -> (canRetryError, 1) -> (traceWait100Continue, 1) -> (Wait100Continue, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (compressBlock, 1) -> (, 0) -> (NewStream, 3) -> (DurationP, 4) -> (DispatchMessageWithRetries, 7) -> (executeRequest, 5) -> (PassThroughHeaders, 1) -> (CheckRetry, 1) -> (truncatingFormat, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Write, 1) -> (printWithFileLine, 6) -> (output, 6) -> (timeoutFlush, 1) -> (DispatchMessageWithRetries, 7) -> (executeRequest, 5) -> (PassThroughHeaders, 1) -> (CheckRetry, 1) -> (truncatingFormat, 1) -> (detectRaces, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (ValueOf, 1) -> (valueOfIface, 1) -> (valueOfBytes, 1) -> (newValidationInfo, 2) -> (DispatchMessageWithRetries, 7) -> (executeRequest, 5) -> (PassThroughHeaders, 1) -> (CheckRetry, 1) -> (truncatingFormat, 1) -> (detectRaces, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (stringOff, 1) -> (WriteString, 1) -> (Get, 0) -> (MatchString, 1) -> (ReadFile, 1) -> (ReadObject, 3) -> (ConfigureTransports, 1) -> (configureTransports, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (String, 0) -> (URL, 1) -> (parseText, 1) -> (next, 0) -> (ConfigureTransport, 1) -> (ConfigureTransports, 1) -> (configureTransports, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Close, 0) -> (Broadcast, 0) -> (conversionHandler, 3) -> (Convert, 2) -> (NewConfigFromMap, 1) -> (levelFromString, 1) -> (lex, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (Close, 0) -> (Broadcast, 0) -> (conversionHandler, 3) -> (Convert, 2) -> (Equal, 3) -> (Equal, 4) -> (formatUnequalValues, 2) -> (truncatingFormat, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Reset, 1) -> (resetMessage, 1) -> (SetUnknown, 1) -> (setUnknown, 2) -> (startFrameWrite, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (Do, 1) -> (transformResponse, 2) -> (isTextResponse, 1) -> (NewGenericServerResponse, 7) -> (RoundTrip, 1) -> (after, 3) -> (shouldEscape, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (Write, 1) -> (printWithFileLine, 6) -> (output, 6) -> (timeoutFlush, 1) -> (handleSuccess, 2) -> (dropPartition, 2) -> (getBrokerProducer, 1) -> (newBrokerProducer, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (open, 0) -> (newObject, 1) -> (toObjectACLRules, 1) -> (toObjectACLRule, 1) -> (getLoggingConfig, 1) -> (ConfigToJSON, 1) -> (levelFromString, 1) -> (lex, 4)
(validateKafkaSecret, 1) -> (String, 2) -> (Equal, 2) -> (cachingEqual, 3) -> (Range, 1) -> (extensionMap, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (write, 3) -> (width, 1) -> (yaml_emitter_set_writer_error, 2) -> (NewImpersonatingRoundTripper, 2) -> (asyncFlush, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Sign, 0) -> (UnscaledBig, 0) -> (Err, 0) -> (Proto, 0) -> (Get, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (compressBlock, 1) -> (, 0) -> (NewStream, 3) -> (DurationP, 4) -> (Cleanup, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (open, 0) -> (newObject, 1) -> (toObjectACLRules, 1) -> (toObjectACLRule, 1) -> (StartConsumerGroup, 4) -> (Consume, 3) -> (release, 1) -> (topicToPartitionNumbers, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Sign, 0) -> (UnscaledBig, 0) -> (Err, 0) -> (Proto, 0) -> (reportCount, 3) -> (ReportCRStatusEvent, 2) -> (createEvent, 2) -> (getRecorder, 4) -> (NewRecorder, 2) -> (recordToSink, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (IsZero, 0) -> (Sign, 0) -> (IsNegative, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (Reset, 1) -> (resetMessage, 1) -> (SetUnknown, 1) -> (setUnknown, 2) -> (startFrameWrite, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Do, 1) -> (transformResponse, 2) -> (isTextResponse, 1) -> (NewGenericServerResponse, 7) -> (StartConsumerGroup, 4) -> (Consume, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (FormatDiff, 2) -> (formatDiffList, 3) -> (CanInterface, 0) -> (fromString, 1) -> (newConsumerGroupClaim, 4) -> (handleError, 3) -> (refBrokerConsumer, 1) -> (newBrokerConsumer, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (Do, 1) -> (transformResponse, 2) -> (isTextResponse, 1) -> (NewGenericServerResponse, 7) -> (StartConsumerGroup, 4) -> (Consume, 3) -> (release, 1) -> (topicToPartitionNumbers, 1)
(validateKafkaSecret, 1) -> (String, 2) -> (Reset, 0) -> (make, 2) -> (, 0) -> (NewStream, 3) -> (Store, 1) -> (packError, 1) -> (Consume, 3) -> (release, 1) -> (topicToPartitionNumbers, 1) -> (Partitions, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Call, 5) -> (RpcError_ErrorCode, 1) -> (convertInterfaceNumbers, 2) -> (convertNumber, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (String, 0) -> (URL, 1) -> (parseText, 1) -> (next, 0) -> (handleSuccess, 2) -> (dropPartition, 2) -> (getBrokerProducer, 1) -> (newBrokerProducer, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (FormatDiff, 2) -> (formatDiffList, 3) -> (CanInterface, 0) -> (fromString, 1) -> (getLoggingConfig, 1) -> (ConfigToJSON, 1) -> (levelFromString, 1) -> (lex, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (nextBlock, 1) -> (println, 1) -> (setPrev, 3) -> (compareSwap, 3) -> (StartConsumerGroup, 4) -> (Consume, 3) -> (release, 1) -> (topicToPartitionNumbers, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (Write, 1) -> (printWithFileLine, 6) -> (output, 6) -> (timeoutFlush, 1) -> (Retrieve, 0) -> (profile, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (FullPath, 0) -> (Free, 0) -> (unref, 0) -> (freeTrace, 1) -> (NewNamedRateLimitingQueue, 2) -> (NewNamedDelayingQueue, 1) -> (NewDelayingQueueWithCustomClock, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Sign, 0) -> (UnscaledBig, 0) -> (Err, 0) -> (Proto, 0) -> (runConcurrent, 2) -> (runWithFriendlyError, 3) -> (run, 3) -> (runCmdContext, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (compressBlock, 1) -> (, 0) -> (NewStream, 3) -> (DurationP, 4) -> (StartConsumerGroup, 4) -> (Consume, 3) -> (release, 1) -> (topicToPartitionNumbers, 1)
(validateKafkaSecret, 1) -> (String, 2) -> (Reset, 0) -> (make, 2) -> (Stop, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (New, 1) -> (HTTPWrappersForConfig, 2) -> (NewImpersonatingRoundTripper, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (FormatDiff, 2) -> (formatDiffList, 3) -> (CanInterface, 0) -> (fromString, 1) -> (newQueue, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (IsZero, 0) -> (Sign, 0) -> (IsNegative, 0) -> (Shutdown, 1) -> (maybeReportTransition, 0)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Close, 0) -> (Broadcast, 0) -> (conversionHandler, 3) -> (Convert, 2) -> (StartConsumerGroup, 4) -> (Consume, 3) -> (release, 1) -> (topicToPartitionNumbers, 1) -> (Partitions, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (Close, 0) -> (Broadcast, 0) -> (conversionHandler, 3) -> (Convert, 2) -> (Equal, 3) -> (Equal, 4) -> (formatUnequalValues, 2) -> (truncatingFormat, 1) -> (SplitAfter, 2)
(validateKafkaSecret, 1) -> (String, 2) -> (Reset, 0) -> (make, 2) -> (Add, 1) -> (insert, 1) -> (evict, 0) -> (evictOldest, 1) -> (Get, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (Close, 0) -> (Broadcast, 0) -> (conversionHandler, 3) -> (Convert, 2) -> (RoundTrip, 1) -> (after, 3) -> (shouldEscape, 1)
(validateKafkaSecret, 1) -> (String, 2) -> (Reset, 0) -> (make, 2) -> (, 0) -> (NewStream, 3) -> (Store, 1) -> (packError, 1) -> (RoundTripOpt, 2) -> (shouldRetryRequest, 3) -> (canRetryError, 1) -> (traceWait100Continue, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (uint64, 1) -> (Write, 1) -> (nextBlock, 1) -> (println, 1) -> (setPrev, 3) -> (compareSwap, 3) -> (sendAndReceiveKerberos, 0) -> (Authorize, 1) -> (readPackage, 1) -> (NewInitiatorWrapToken, 2) -> (SetCheckSum, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Get, 0) -> (MatchString, 1) -> (ReadFile, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (prepareNext, 1) -> (append, 3) -> (BoolVar, 1) -> (typeName, 0) -> (asyncFlush, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Load, 0) -> (UntypedLoad, 1) -> (DeepCopyObject, 0) -> (andTerm, 1) -> (asyncFlush, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Close, 0) -> (Broadcast, 0) -> (conversionHandler, 3) -> (Convert, 2) -> (poller, 2)
(validateKafkaSecret, 1) -> (string, 1) -> (stringOff, 1) -> (WriteString, 1) -> (prepareNext, 1) -> (, 0) -> (NewStream, 3) -> (DurationP, 4) -> (RoundTrip, 1) -> (after, 3) -> (shouldEscape, 1) -> (legalHeaderByte, 1) -> (GroupVersions, 1)
(validateKafkaSecret, 1) -> (String, 2) -> (Reset, 0) -> (make, 2) -> (init, 0) -> (UTC, 0) -> (setCurMetricsConfig, 1) -> (setCurMetricsConfigUnlocked, 1) -> (updateClientConnState, 1) -> (UpdateClientConnState, 1) -> (UpdateAddresses, 1) -> (newAddrConn, 2) -> (RegisterSubChannel, 3) -> (addSubChannel, 4) -> (GetFallbackResponse, 0) -> (newClientStream, 5)
(validateKafkaSecret, 1) -> (String, 2) -> (Reset, 0) -> (make, 2) -> (, 0) -> (NewStream, 3) -> (Store, 1) -> (packError, 1) -> (RoundTripOpt, 2) -> (shouldRetryRequest, 3) -> (canRetryError, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (nextBlock, 1) -> (println, 1) -> (setPrev, 3) -> (compareSwap, 3) -> (getLoggingConfig, 1) -> (ConfigToJSON, 1) -> (levelFromString, 1) -> (lex, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (Close, 0) -> (Broadcast, 0) -> (conversionHandler, 3) -> (Convert, 2) -> (getLoggingConfig, 1) -> (ConfigToJSON, 1) -> (levelFromString, 1) -> (lex, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (Write, 1) -> (printWithFileLine, 6) -> (output, 6) -> (timeoutFlush, 1) -> (connect, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (IsZero, 0) -> (Sign, 0) -> (IsNegative, 0) -> (Shutdown, 1) -> (handleRawConn, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (int64, 1) -> (Write, 1) -> (compressBlock, 1) -> (, 0) -> (NewStream, 3) -> (DurationP, 4) -> (StartConsumerGroup, 4)
(validateKafkaSecret, 1) -> (string, 1) -> (marker, 1) -> (errorf, 3) -> (String, 0) -> (URL, 1) -> (parseText, 1) -> (next, 0) -> (Watch, 1) -> (WatchFunc, 1)
(validateKafkaSecret, 1) -> (String, 2) -> (Reset, 0) -> (make, 2) -> (, 0) -> (NewStream, 3) -> (Store, 1) -> (packError, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Get, 0) -> (MatchString, 1) -> (ReadFile, 1) -> (ReadObject, 3) -> (startFrameWrite, 1)
(validateKafkaSecret, 1) -> (string, 1) -> (stringOff, 1) -> (WriteString, 1) -> (prepareNext, 1) -> (, 0) -> (NewStream, 3) -> (DurationP, 4) -> (StartConsumerGroup, 4) -> (Consume, 3)
(validateKafkaSecret, 1) -> (string, 1) -> (tracef, 2) -> (String, 0) -> (Start, 0) -> (start, 0) -> (UpdateState, 1) -> (updateResolverState, 2) -> (ConfigureTransport, 1) -> (ConfigureTransports, 1) -> (configureTransports, 1) -> (addConnIfNeeded, 3)
```
Leave a reaction on this issue to contribute to the project by classifying this instance as a **Bug** :-1:, **Mitigated** :+1:, or **Desirable Behavior** :rocket:
See the descriptions of the classifications [here](https://github.com/github-vet/rangeclosure-findings#how-can-i-help) for more information.
commit ID: 3d1488fcf8244a6299956994fc08fc3c53354ffb
Contributor guide
No contributing guide indexed for this repository
Assessment
This issue has not been assessed yet.