Keda operator facing issue in finding offset block #4215

sinanub18 · 2023-02-08T16:54:20Z

Report

Getting error from keda operator saying "error":"error finding offset block for topic XXX-XXX-XXX and partition 1"

{"level":"error","ts":"2023-02-08T16:47:13Z","logger":"kafka_scaler","msg":"","type":"ScaledObject","namespace":"XXX","name":"XXX-XXX-XXX","error":"error finding offset block for topic XXX.XXX-XXX and partition 1","stacktrace":"github.com/kedacore/keda/v2/pkg/scalers.(*kafkaScaler).getLagForPartition\n\t/workspace/pkg/scalers/kafka_scaler.go:448\ngithub.com/kedacore/keda/v2/pkg/scalers.(*kafkaScaler).getTotalLag\n\t/workspace/pkg/scalers/kafka_scaler.go:597\ngithub.com/kedacore/keda/v2/pkg/scalers.(*kafkaScaler).GetMetricsAndActivity\n\t/workspace/pkg/scalers/kafka_scaler.go:568\ngithub.com/kedacore/keda/v2/pkg/scaling/cache.(*ScalersCache).GetMetricsForScaler\n\t/workspace/pkg/scaling/cache/scalers_cache.go:77\ngithub.com/kedacore/keda/v2/pkg/scaling.(*scaleHandler).GetScaledObjectMetrics\n\t/workspace/pkg/scaling/scale_handler.go:439\ngithub.com/kedacore/keda/v2/pkg/metricsservice.(*GrpcServer).GetMetrics\n\t/workspace/pkg/metricsservice/server.go:45\ngithub.com/kedacore/keda/v2/pkg/metricsservice/api._MetricsService_GetMetrics_Handler\n\t/workspace/pkg/metricsservice/api/metrics_grpc.pb.go:79\ngoogle.golang.org/grpc.(*Server).processUnaryRPC\n\t/workspace/vendor/google.golang.org/grpc/server.go:1340\ngoogle.golang.org/grpc.(*Server).handleStream\n\t/workspace/vendor/google.golang.org/grpc/server.go:1713\ngoogle.golang.org/grpc.(*Server).serveStreams.func1.2\n\t/workspace/vendor/google.golang.org/grpc/server.go:965"}

Expected Behavior

Keda operator should face issue to find offset block

Actual Behavior

Throws error with error finding offset block for topic

Steps to Reproduce the Problem

Deploy KEDA 2.9.0
Check logs of keda operator

Logs from KEDA operator

{"level":"error","ts":"2023-02-08T16:47:13Z","logger":"kafka_scaler","msg":"","type":"ScaledObject","namespace":"YYY","name":"XXX-XXX,"error":"error finding offset block for topic XX.XXX-XXX and partition 2","stacktrace":"github.com/kedacore/keda/v2/pkg/scalers.(*kafkaScaler).getLagForPartition\n\t/workspace/pkg/scalers/kafka_scaler.go:448\ngithub.com/kedacore/keda/v2/pkg/scalers.(*kafkaScaler).getTotalLag\n\t/workspace/pkg/scalers/kafka_scaler.go:597\ngithub.com/kedacore/keda/v2/pkg/scalers.(*kafkaScaler).GetMetricsAndActivity\n\t/workspace/pkg/scalers/kafka_scaler.go:568\ngithub.com/kedacore/keda/v2/pkg/scaling/cache.(*ScalersCache).GetMetricsForScaler\n\t/workspace/pkg/scaling/cache/scalers_cache.go:77\ngithub.com/kedacore/keda/v2/pkg/scaling.(*scaleHandler).GetScaledObjectMetrics\n\t/workspace/pkg/scaling/scale_handler.go:439\ngithub.com/kedacore/keda/v2/pkg/metricsservice.(*GrpcServer).GetMetrics\n\t/workspace/pkg/metricsservice/server.go:45\ngithub.com/kedacore/keda/v2/pkg/metricsservice/api._MetricsService_GetMetrics_Handler\n\t/workspace/pkg/metricsservice/api/metrics_grpc.pb.go:79\ngoogle.golang.org/grpc.(*Server).processUnaryRPC\n\t/workspace/vendor/google.golang.org/grpc/server.go:1340\ngoogle.golang.org/grpc.(*Server).handleStream\n\t/workspace/vendor/google.golang.org/grpc/server.go:1713\ngoogle.golang.org/grpc.(*Server).serveStreams.func1.2\n\t/workspace/vendor/google.golang.org/grpc/server.go:965"}

KEDA Version

2.9.0

Kubernetes Version

1.25

Platform

Google Cloud

Scaler Details

Kafka Scaler

Anything else?

No response

The text was updated successfully, but these errors were encountered:

JorTurFer · 2023-02-08T23:28:12Z

Any idea about this @zroubalik ?

zroubalik · 2023-02-09T10:13:25Z

Try to check this setting: https://keda.sh/docs/2.9/scalers/apache-kafka/#new-consumers-and-offset-reset-policy

sinanub18 · 2023-02-09T14:57:50Z

Try to check this setting: https://keda.sh/docs/2.9/scalers/apache-kafka/#new-consumers-and-offset-reset-policy

@zroubalik The ScaledObjets already have the variable offsetResetPolicy: latest for kafka scalers

jorgenfries · 2023-03-09T10:03:14Z

Experiencing the same issue, and log errors.
Workaround is restarting keda operator pod :-/
Status on the specific scaledobjects are fine - no errors are logged here.

Chart version: helm.sh/chart=keda-2.9.4

dttung2905 · 2023-03-13T13:58:26Z

@jorgenfries could you help to try with keda 2.10 if possible ? This version will have better error logging from PR #4233. It won't directly solve your problem but might provide more information for troubleshooting at least 🙏

jorgenfries · 2023-03-13T14:09:15Z

@dttung2905
Updated this weekend. helm.sh/chart=keda-2.10.0
Will post the output when/if it happens again.

johnnytardin · 2023-03-21T14:14:03Z

@jorgenfries did you notice the error still occurring after the update to 2.10.0?

jorgenfries · 2023-03-24T08:59:55Z

@johnnytardin - Actually I haven't seen it since. However I only noticed it once with the earlier version.
I am performing some intensive testing on our Kafka workloads the coming month, so if it's still present I should encounter it again soonish.

johnnytardin · 2023-03-27T18:35:05Z

I performed the update last week to 2.10.0 and continue to get the errors.
Here is the log but without further information.

"error finding offset block for topic [HIDDEN] and partition 13 from offset block: map[]"

"error finding offset block for topic [HIDDEN] and partition 0 from offset block: map[]"

"error finding offset block for topic [HIDDEN] 4 from offset block: map[]"

"error finding offset block for topic [HIDDEN] 1 from offset block: map[]"

jorgenfries · 2023-03-29T10:54:43Z

I experienced it again also with 2.10.0 - same log entries as @johnnytardin
Sadly I recreated the pod without getting the logs out before doing so -.-
However a pod restart of keda-operator fixed it again, and the scaling started correctly again.

dttung2905 · 2023-03-29T15:02:50Z

"error finding offset block for topic [HIDDEN] and partition 13 from offset block: map[]"

Its quite weird actually. From your log (which was added since 2.10 ), the offset block map is empty which could be eventually traced back to this method call

keda/pkg/scalers/kafka_scaler.go

Lines 469 to 479 in ee28bf6

    
           func (s *kafkaScaler) getConsumerOffsets(topicPartitions map[string][]int32) (*sarama.OffsetFetchResponse, error) { 
        
           	offsets, err := s.admin.ListConsumerGroupOffsets(s.metadata.group, topicPartitions) 
        
           	if err != nil { 
        
           		return nil, fmt.Errorf("error listing consumer group offsets: %w", err) 
        
           	} 
        
           	if offsets.Err > 0 { 
        
           		errMsg := fmt.Errorf("error listing consumer group offsets: %w", offsets.Err) 
        
           		s.logger.Error(errMsg, "") 
        
           	} 
        
           	return offsets, nil 
        
           }

which uses ListConsumerGroupOffsets() from the samara library. Might have something to do with samara itself idk. I'm not too sure as @jorgenfries said the error went away after pod recreation 🤔 ( which makes it even harder to reproduce consistantly ). Do you have any other ideas @JorTurFer @zroubalik ?

sansmoraxz · 2023-04-22T18:14:35Z

Not sure if entirely related but I was facing something similar #4466
Except that it wasn't logging any errors.

Restarting the keda-operator at least seemed to fix it (temporarily).

oshmoun · 2023-04-28T09:40:00Z

just had the issue here as well, here is the stacktrace from the logs

2023-04-28T09:31:42Z	ERROR	kafka_scaler		{"type": "ScaledObject", "namespace": "HIDDEN", "name": "HIDDEN", "error": "error finding offset block for topic HIDDEN and partition 4"}
github.com/kedacore/keda/v2/pkg/scalers.(*kafkaScaler).getLagForPartition
	/workspace/pkg/scalers/kafka_scaler.go:448
github.com/kedacore/keda/v2/pkg/scalers.(*kafkaScaler).getTotalLag
	/workspace/pkg/scalers/kafka_scaler.go:597
github.com/kedacore/keda/v2/pkg/scalers.(*kafkaScaler).GetMetricsAndActivity
	/workspace/pkg/scalers/kafka_scaler.go:568

I'm on version 2.9.3

I did not need to restart keda to fix the issue, but simply disable idle scaling by removing idleReplicaCount from the configured ScaledObjects

JorTurFer · 2023-05-01T21:36:34Z

I did not need to restart keda to fix the issue, but simply disable idle scaling by removing idleReplicaCount from the configured ScaledObjects

idleReplicaCount doesn't have impact at scaler level, it's something external for KEDA itself, not for kafka trigger, I think that your problem has gone because modifying the ScaledObject you have triggered a rebuild of the scaler

JorTurFer · 2023-05-01T21:46:37Z

Could it be related with some internal change in sarama client? AFAIR, there isn't any change in kafka scaler related with that code?
@zroubalik ?

oshmoun · 2023-05-03T13:04:44Z

I did not need to restart keda to fix the issue, but simply disable idle scaling by removing idleReplicaCount from the configured ScaledObjects

idleReplicaCount doesn't have impact at scaler level, it's something external for KEDA itself, not for kafka trigger, I think that your problem has gone because modifying the ScaledObject you have triggered a rebuild of the scaler

of course you are correct. The issue just re-occurred today with idle scaling deactivated.

sinanub18 · 2023-05-30T11:20:24Z

Could it be related with some internal change in sarama client? AFAIR, there isn't any change in kafka scaler related with that code? @zroubalik ?

Hi @JorTurFer Its not about recent changes as I am facing this issue since 2.6.0

oshmoun · 2023-06-12T08:52:42Z

Would like to also mention that I have tested fallback scaling, hoping that keda would at least respect that in the case of this scaling failure, but it does not. Fallback scaling is rendered broken when this issue occurs.

JorTurFer · 2023-06-12T17:26:05Z

Do you have a way to reproduce this error?

oshmoun · 2023-06-13T08:56:35Z

Do you have a way to reproduce this error?

unfortunately not, as it happens randomly
though if you are referring to the fallback scaling failure, I guess one can simply introduce an error in the code where the current error is reported, and check from there

github.com/kedacore/keda/v2/pkg/scalers.(*kafkaScaler).getLagForPartition
	/workspace/pkg/scalers/kafka_scaler.go:448

JorTurFer · 2023-06-13T16:27:26Z

though if you are referring to the fallback scaling failure

No no, I meant the root cause

oshmoun · 2023-07-31T17:38:46Z

sorry for the lack of update on this matter. I have updated keda to 2.11.1, and since then the issue has not occurred. Hopefully not just a fluke, since the issue is of random nature.
But so far so good 🤞

stale · 2023-09-29T22:08:28Z

This issue has been automatically marked as stale because it has not had recent activity. It will be closed in 7 days if no further activity occurs. Thank you for your contributions.

leoeareis · 2023-10-03T14:29:56Z

Any update related to that @oshmoun in new version?

oshmoun · 2023-10-03T14:36:33Z

Any update related to that @oshmoun in new version?

Sorry for the lack of updates. Ever since updating the issue has not occurred, and keda scaling has been working smoothly.
I guess in this scenario the saying "no news is good news" applies perfectly 🙂

JorTurFer · 2023-10-03T21:12:43Z

As it looks as solved, I'm going to close the issue. If the problem happens again, comment here and I can reopen it.
Just to announce it, we have added another "flavour" of kafka scaler as experimental scaler: https://keda.sh/docs/2.12/scalers/apache-kafka-go/
It's experimental because it doesn't have all the functionality yet, but it uses kafka-go instead of sarama client. It's covered by e2e test cases and even though there could be a missing test, the majority of them are the same (I mean, it's not just random code placed there). You can give a try too if the issue persists

rxg8255 · 2023-10-17T00:52:04Z

Facing same issue, K8s version 1.25 and KEDA 2.9.3
Tried restarting the KEDA operator but no luck.
Could any please let me know = the fix?

sansmoraxz · 2023-10-17T05:27:32Z

@rxg8255 can you update your KEDA operator to newer versions viz 2.12.0 and check if it still gives the same issue?

Alternatively, have a look at Apache Kafka - (Experimental) and if your use case is supported check if issue persists.

rxg8255 · 2023-10-17T13:37:35Z

Thanks for the details @sansmoraxz. Is there any work around for the issue apart from upgrading it to 2.12.0 As the upgrade will take quite a time as we cannot upgrade immediately.

sansmoraxz · 2023-10-17T20:04:07Z

Maybe try resetting your consumer group and/ or topic. Not sure if it would help.

I think there was a bug in the underlying dependency solved in 2.11 as @oshmoun stated above. #4215 (comment)

rxg8255 · 2023-10-17T20:05:32Z

@tomkerkhove @zroubalik
@sansmoraxz
Currently we are on AKS version 1.25 and the compatibility matrix says K8s version v1.26 - v1.28 is compatible with latest KEDA version i.e. 2.12.

Sure, we will upgrade KEDA to 2.11 to test the scenario and will keep you posted.

sinanub18 added the bug Something isn't working label Feb 8, 2023

sinanub18 mentioned this issue Feb 8, 2023

Kafka scaler stops working until pods are restarted #2484

Closed

dttung2905 mentioned this issue Feb 13, 2023

Kafka Scaler: Improve error logging for GetBlock() method #4232

Closed

stale bot added the stale All issues that are marked as stale due to inactivity label Sep 29, 2023

JorTurFer closed this as completed Oct 3, 2023

stale bot removed the stale All issues that are marked as stale due to inactivity label Oct 3, 2023

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Keda operator facing issue in finding offset block #4215

Keda operator facing issue in finding offset block #4215

sinanub18 commented Feb 8, 2023

JorTurFer commented Feb 8, 2023

zroubalik commented Feb 9, 2023

sinanub18 commented Feb 9, 2023 •

edited

Loading

jorgenfries commented Mar 9, 2023 •

edited

Loading

dttung2905 commented Mar 13, 2023

jorgenfries commented Mar 13, 2023

johnnytardin commented Mar 21, 2023

jorgenfries commented Mar 24, 2023

johnnytardin commented Mar 27, 2023 •

edited

Loading

jorgenfries commented Mar 29, 2023

dttung2905 commented Mar 29, 2023

sansmoraxz commented Apr 22, 2023

oshmoun commented Apr 28, 2023 •

edited

Loading

JorTurFer commented May 1, 2023

JorTurFer commented May 1, 2023

oshmoun commented May 3, 2023

sinanub18 commented May 30, 2023

oshmoun commented Jun 12, 2023

JorTurFer commented Jun 12, 2023

oshmoun commented Jun 13, 2023

JorTurFer commented Jun 13, 2023

oshmoun commented Jul 31, 2023

stale bot commented Sep 29, 2023

leoeareis commented Oct 3, 2023

oshmoun commented Oct 3, 2023

JorTurFer commented Oct 3, 2023

rxg8255 commented Oct 17, 2023

sansmoraxz commented Oct 17, 2023

rxg8255 commented Oct 17, 2023

sansmoraxz commented Oct 17, 2023

rxg8255 commented Oct 17, 2023

Keda operator facing issue in finding offset block #4215

Keda operator facing issue in finding offset block #4215

Comments

sinanub18 commented Feb 8, 2023

Report

Expected Behavior

Actual Behavior

Steps to Reproduce the Problem

Logs from KEDA operator

KEDA Version

Kubernetes Version

Platform

Scaler Details

Anything else?

JorTurFer commented Feb 8, 2023

zroubalik commented Feb 9, 2023

sinanub18 commented Feb 9, 2023 • edited Loading

jorgenfries commented Mar 9, 2023 • edited Loading

dttung2905 commented Mar 13, 2023

jorgenfries commented Mar 13, 2023

johnnytardin commented Mar 21, 2023

jorgenfries commented Mar 24, 2023

johnnytardin commented Mar 27, 2023 • edited Loading

jorgenfries commented Mar 29, 2023

dttung2905 commented Mar 29, 2023

sansmoraxz commented Apr 22, 2023

oshmoun commented Apr 28, 2023 • edited Loading

JorTurFer commented May 1, 2023

JorTurFer commented May 1, 2023

oshmoun commented May 3, 2023

sinanub18 commented May 30, 2023

oshmoun commented Jun 12, 2023

JorTurFer commented Jun 12, 2023

oshmoun commented Jun 13, 2023

JorTurFer commented Jun 13, 2023

oshmoun commented Jul 31, 2023

stale bot commented Sep 29, 2023

leoeareis commented Oct 3, 2023

oshmoun commented Oct 3, 2023

JorTurFer commented Oct 3, 2023

rxg8255 commented Oct 17, 2023

sansmoraxz commented Oct 17, 2023

rxg8255 commented Oct 17, 2023

sansmoraxz commented Oct 17, 2023

rxg8255 commented Oct 17, 2023

sinanub18 commented Feb 9, 2023 •

edited

Loading

jorgenfries commented Mar 9, 2023 •

edited

Loading

johnnytardin commented Mar 27, 2023 •

edited

Loading

oshmoun commented Apr 28, 2023 •

edited

Loading