[jira] [Created] (PLC4X-139) PLC4X leaks sockets in case of connection problems

2019-08-02 Thread Julian Feinauer (JIRA)
Julian Feinauer created PLC4X-139: - Summary: PLC4X leaks sockets in case of connection problems Key: PLC4X-139 URL: https://issues.apache.org/jira/browse/PLC4X-139 Project: Apache PLC4X Issue

Re: Are we leaking sockets?

2019-08-02 Thread Julian Feinauer
Hey, agree @cdutz... I am just running an example and it really seems like that. So I'll try to finish a MWE and perhaps ask on the netty list : ) Julian Am 02.08.19, 16:58 schrieb "Christofer Dutz" : Hi Julian, Well if I look into my sock drawer at home I think we might be leakin

Re: Are we leaking sockets?

2019-08-02 Thread Christofer Dutz
Hi Julian, Well if I look into my sock drawer at home I think we might be leaking some socks ... I agree ... there are several single-socks in there ;-) But regarding netty ... yes it is absolutely possible we're not handling this correctly as the docs are quite extensive and I didn't bother re

Are we leaking sockets?

2019-08-02 Thread Julian Feinauer
Hi all, we observe a strange behavior in production. We are still investigating the exact scenario and it’s a bit complex as we have many connections to many plcs and fire many requests through many different channels… But what we observe is that we get the well known “too many open files” Exce

AW: [KAFKA] Refactoring the Kafka Connect plugin?

2019-08-02 Thread Julian Feinauer
Hi, I think that's the best way then. I agree with your suggestion. Julian Von meinem Mobiltelefon gesendet Ursprüngliche Nachricht Betreff: Re: [KAFKA] Refactoring the Kafka Connect plugin? Von: Christofer Dutz An: dev@plc4x.apache.org Cc: Hi all, Ok so it seems that Kafk

Re: [KAFKA] Refactoring the Kafka Connect plugin?

2019-08-02 Thread Christofer Dutz
Hi all, Ok so it seems that Kafka only supports configuration via simple unstructured maps. So if we want some hierarchical configuration like the proposed one, we'll have to do it log4j.properties-style: name=plc-source-test connector.class=org.apache.plc4x.kafka.Plc4xSourceConnector default