Thomas

Question : How can I consume my kafka topic as fast as possible ?

22

Hi, I'm using Kafka between ruby and scala and I noticed that my ruby HermannConsumer is consuming message faster than my AkkaConsumer. I can set commitConfig = CommitConfig(commitInterval = Some(10...

PubsubAvroToBigQuery fails to insert in BigQuery and lost messages

1

Here is my experience using PubsubAvroToBigQuery template. A new field was added into the avro schema used to serialize the message send to Pub/Sub. I updated the schema in Dataflow...

Using allOf with cross_spec doesn't generate import in model

4

Hi, I have two models : ``` swagger: '2.0' info: version: 1.0.0 paths: definitions: entity: type: object properties: id: type: string format: uuid example: "2ad91139-c3bc-420b-91a8-8aa9409aea07" created_at: type: string format: date-time...

Jackson Serializer/Deserializer

2

Hi, I'm trying to find a way to create Jackson Serializer/Deserializer for Account and Groups. I'm currently using : ``` public class AccountSerializer extends StdSerializer { protected AccountSerializer() { super(Account.class);...

Check for stable-margin before going to onSufficientContactPointsDiscovered ?

1

Here are my observations : I have 3 running instances with adresses (10, 11, 12), and the default configuration (`stable-margin = 5 seconds` and `required-contact-point-nr = 2`). On the first...

Session is NOT explicitly destroyed during clean shutdown

3

Hi, - I'm using constructr inside nomad Tasks running Lagom inside a docker image. - I might have multiple Tasks on one node. - I have one consul agent per...

Anchor Tabular - KeyError in get_features_index

5

I have the following error when trying to call explain on an AnchorTabular fitted on a mixed of numerical and categorical data. On alibi 0.9.2. ``` Error Traceback (most recent...

MoneyContext should be abstract class

5

Hi, I'm trying to tweak the MoneyContext but being a case class make it really hard. Could we create an abstraction ?

Resolution shouldn't be random on the nameservers

1

I found the behavior in the line quite odd. https://github.com/ilya-epifanov/akka-dns/blob/adbaf294db6c08dadc6eef061860e2329a43b62a/src/main/scala/akka/io/AsyncDnsResolver.scala#L77 Usually, when working with dns, the second `nameservers` is only used if the first is not responding.

Hi, I have 3 allocs and a consul cluster. When using dig to resolveSRV my service at `_tpocreau-connectors-bot-builder-app-akka-management._tcp.service.consul ` I got the 3 allocs but using IO(Dns) I only get...