kafka-client

It would be nice to be able to augment cache hit ratio metrics with how many requests were marked as uncacheable, which could be done by adding the MAIN.beresp_uncacheable metric to the metrics already being pulled from Varnish.

I use Array<Uint8Array> as a value. But The uint8Array is treated as string.

function arrayString(val) {
  var result = '{'
  for (var i = 0; i < val.length; i++) {
    if (i > 0) {
      result = result + ','
    }
    if (val[i] === null || typeof val[i] === 'undefined') {
      result = result + 'NULL'
    } else if (Array.isArray(val[i])) {
      result = result + arrayStr

Current behavior:
All the SQL activities either don't support Insert or are specific to a usecase

Expected behavior:
to be able to insert to a sql database in an activity

What is the motivation / use case for changing the behavior?
many workflows/pipelines require logging to a database

Additional information you deem important (e.g. I need this tomorrow):

Right now, all the elements of the breadcrumb are capitalized. This is a bug because we are supposed to leave names as-is. For example, if some topic is called dummy-topic, the breacrumb should look like this:
Topics / dummy-topic
But now it looks like this:
Topics / Dummy-topic

based on: https://kafka.js.org/docs/configuration and tulios/kafkajs#298
We may not have the correct settings for the JSConsumer and JSProducer. This issue is to ensure we have them up to date after nodefluent/node-sinek#154 has been merged

Similarly to #234, it would be useful to provide functions for creating test KafkaProducers.

A good first function would be one which yields somewhat sensible default RecordMetadata.

object KafkaProducer {
  def unit[F[_], K, V](implicit F: Sync[F]): F[KafkaProducer[F, K, V]] = ???
}

Likely, this would require some internal state, hence F[KafkaProducer[F, K, V]].