Chris Sun

How do you test the Websocket?

12

I am playing with WebSocket streaming data. How could you do testing aftermarket hours when there are no data from the WebSocket?

Additional env for kafka connect?

1

Does Landoop Kafka connect support some env like that in Confluent Kafka connect? such as CONNECTOR_CLIENT_CONFIG_OVERRIDE_POLICY: All # set offset reset in connectors to latest or earliest CONFIG_PROVIDERS: file #...

Have to restart the service sometimes

1

It works well when I just started the service. I tried to run some jobs at the same time and they all can get data, but sometimes when I stopped...

Datatype standardization before comparing for dataframes from DASK or Pyspark

1

In most cases, datacompy works very well for the comparison at the cell level. But I have met a few cases when I converted the datafrom from DASK or Pyspark...

How to stop consumer.

1

I know this is a silly question, but I don't know how to do that. I try to check if message is None, but the consumer just stops consuming if...

Rounding issue for decimal.

1

I am trying to use ctds build_insert to insert a list of dictionaries to mssql. I found something unusual, for the column defined as numeric(8,2). The float 77.4930 will be...