Re: How to handle JDBC connections in a topology

2019-07-24 Thread Chesnay Schepler
Note that in order for the static class approach to work you have to ensure that the class is loaded by the parent classloader, either by placing the class in /lib or configuring `classloader.parent-first-patterns-additional` to pick up this particular class. On 24/07/2019 10:24, Haibo Sun wr

Re:Re: How to handle JDBC connections in a topology

2019-07-24 Thread Haibo Sun
Hi Stephen, I don't think it's possible to use the same connection pool for the entire topology, because the nodes on the topology may run in different JVMs and on different machines. If you want all operators running in the same JVM to use the same connection pool, I think you can implement

Re: How to handle JDBC connections in a topology

2019-07-24 Thread Stephen Connolly
Oh and I'd also need some way to clean up the per-node transient state if the topology stops running on a specific node. On Wed, 24 Jul 2019 at 08:18, Stephen Connolly < stephen.alan.conno...@gmail.com> wrote: > Hi, > > So we have a number of nodes in our topology that need to do things like > ch

How to handle JDBC connections in a topology

2019-07-24 Thread Stephen Connolly
Hi, So we have a number of nodes in our topology that need to do things like checking a database, e.g. * We need a filter step to drop events on the floor from systems we are no longer interested in * We need a step that outputs on a side-channel if the event is for an object where the parent is