Harish-Sridhar

Version conflict when consuming records same same partition

3

Hi, Recently i faced the version conflict issue when providing a key as id to index documents to Elastic search. It is because the offset of the consumed record is...

Need help and clarity on the instructions.

1

The instructions to setup the DNS server are not clear for me. Can you please help? 1. What are these DNS names `log4jchecker.northwave.nl`, `log4jdnsreq.northwave.nl`. 2. Where do we need to...

Handle additional dependencies

4

Hi, In the flink-jpmml documentation, it is mentioned that the dependency to be added to projects is as follows. ``` "io.radicalbit" %% "flink-jpmml-scala" % "0.6.3" ``` But when I tried...

Integer Type Target value not supported

1

Hi, The model I used to test the flink-jpmml library had the target value as Integer type. Following is the target field from the PMML model I used. ``` ```...

How can a user enter an empty string as input to a prompt when the default value is not an empty string

4

* Cookiecutter version: 1.7.2 * Template project url: * Python version: * Operating System: ### Description: I have the following cookiecutter.json. ``` { namespace: "abc" } ``` when I prompt...

Teradata Sink failed to get initialized

1

Hi, I have installed kafka-connect-jdbc connector from confluent hub, version 10.2.0. I have also installed the latest teradata jdbc 4 driver. and put it in the path `/usr/share/confluent-hub-components/confluentinc-kafka-connect-jdbc/lib` When i...