Hacktoberfest 2026: the issues maintainers tagged for October, open and beginner-friendly. Browse Hacktoberfest issues

ethconnect crash

Open
#43 0 comments 0 reactions 0 assignees View on GitHub

Nobody has claimed this yet.

Assessment

Difficulty
3/5
Estimated time
1-2 days
Newbie friendliness
35/100
Issue type
Bug
Clarity
Needs clarification
Activity status
Stale
Tech stack
go, kafka
Domain
backend

Research direction

Start with internal/kldkafka/client.go at line 211, then follow the call from internal/kldrest/webhookskafka.go line 84 and the consumer startup in internal/kldkafka/kafkacommon.go line 249. Reproduce or trace the performance-test crash and identify the nil value reached by MarkOffset; done means the consumer no longer panics in this scenario.

Written by the indexing model from the issue text.

Description

from one of our performance testing runs we observed a crash with the following logs:

time="2020-01-24T04:14:51Z" level=info msg="Consumer session cleanup. Claims=map[zzo8ywgn54-zzax9xn2pu-replies:[0]] Member=2984c4ea-2db0-4ef2-6974-a16743d14c52-36b90936-e43f-4ee1-9580-106481b21fdb Generation=7"
time="2020-01-24T04:14:51Z" level=info msg="Inserted receipt 3f7ab219-d070-4e1f-7a2e-1050974354c0 into receipt store"
panic: runtime error: invalid memory address or nil pointer dereference
[signal SIGSEGV: segmentation violation code=0x1 addr=0x30 pc=0x9f46ed]
goroutine 188 [running]:
github.com/kaleido-io/ethconnect/internal/kldkafka.(*saramaKafkaConsumerGroupHandler).MarkOffset(0xc0013c4000, 0xc03ffbafa0, 0x0, 0x0)
	/kaleido-io/ethconnect/internal/kldkafka/client.go:211 +0x2d
github.com/kaleido-io/ethconnect/internal/kldrest.(*webhooksKafka).ConsumerMessagesLoop(0xc00012c740, 0xf2b500, 0xc0013c4000, 0x7f702412a4d0, 0xc0013bb3b0, 0xc0004c80d8)
	/kaleido-io/ethconnect/internal/kldrest/webhookskafka.go:84 +0xb0
created by github.com/kaleido-io/ethconnect/internal/kldkafka.(*kafkaCommon).startConsumer
	/kaleido-io/ethconnect/internal/kldkafka/kafkacommon.go:249 +0xbf
Copyright (C) 2018,2019 Kaleido
Licensed under the Apache License, Version 2.0
Version: it-1579124042156 (Build Date: 2020-01-15T21:35:18Z)
time="2020-01-24T04:14:52Z" level=info msg="Starting REST gateway 'rest-gateway'"
time="2020-01-24T04:14:52Z" level=info msg="New JSON/RPC connection established"
time="2020-01-24T04:14:52Z" level=info msg="OpenAPI Smart Contract Gateway configured with base URL 'https://zzo8ywgn54-zzax9xn2pu-connect.dev2.photic.io'"
time="2020-01-24T04:14:52Z" level=info msg="Starting Kafka->Ethereum bridge 'kafka-tx-streaming'"
Dominant language
Go
Stars
76
Forks
31
PR merge metrics
No merged PRs in 30d

Getting set up

First steps

  1. Read the whole issue, then the project's contributing guide.
  2. Comment on the issue to say you are picking it up — it saves two people doing the same work.
  3. Fork the repository and make your change on a branch.
  4. Open a pull request that references the issue number.

More from hyperledger-firefly/ethconnect

All issues in hyperledger-firefly/ethconnect

Similar issues

More Go issues

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.