integration of SAN fails

Hi shimaore,

it looks like the Kafka consumer is failing. Can you send us logs?

Note a short problem description in the text field of the upload form.

cd /home/stor2rrd/stor2rrd # or where is your STOR2RRD working dir
tar cvhf logs.tar logs tmp/*txt
gzip -9 logs.tar

Send us logs.tar.gz via https://upload.stor2rrd.com

Hi all,

Kafka consumer daemon didn't work because there were old versions of librdkafka and kafkian.

The issue was resolved after reinstalling librdkafka and kafian to the latest versions.

You can identify this issue by this error in the kafka consumer error log:

cd /home/stor2rrd/stor2rrd # or where is your STOR2RRD working dir
cat logs/error.log-kafka-consumer-<Kafka hostname or IP>

Traceback (most recent call last):
 File "/stor2rrd/stor2rrd/bin/sannavperf.py", line 51, in <module>
    value_deserializer=AvroDeserializer(schema_registry_url=f'http://{ip}:{schema_port}'),
 File "/usr/lib64/python3.6/site-packages/kafkian/consumer.py", line 76, in __init__
  self._consumer_impl = self._init_consumer_impl(config)
 File "/usr/lib64/python3.6/site-packages/kafkian/consumer.py", line 81, in _init_consumer_impl
  return ConfluentConsumer(config, logger=logging.getLogger("librdkafka.consumer"))
cimpl.KafkaException: KafkaError{code=_INVALID_ARG,val=-186,str="Property "throttle_cb" must be set through dedicated .._set_..() function"}
Error in atexit._run_exitfuncs:
Traceback (most recent call last):
 File "/usr/lib64/python3.6/site-packages/kafkian/consumer.py", line 117, in _close
self._consumer_impl.close()
AttributeError: 'Consumer' object has no attribute '_consumer_impl'

Here are versions we're using in our labs: