ethconnect crash

[jimthematrix]

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'"