search

siddhi-io / siddhi-io-kafka

Extension that can be used to receive events from a Kafka cluster and to publish events to a Kafka cluster
https://siddhi-io.github.io/siddhi-io-kafka/
Apache License 2.0
18 stars 50 forks source link

Replace ScheduledExecutorService with ExecutorService #121

Closed sahandilshan closed 5 years ago

sahandilshan commented 5 years ago

Purpose

Resolve #80

Goals

Get ExecutorService from SiddhiAppcontext instead of ScheduledExecutorService.

Approach

Earlier siddhi-io-kafka source used ScheduledExecutorService from SiddhiAppContext to handle partition wise threads and that SheduledExecuterService has only 5 threadpools. So Kafka source can't handle more than 5 partition even though the user provides more than 5 partitions from the partition.no.list parameter. In order to solve this, ExecutoreService is used instead of SheduleExecutorService from the SiddhiAppContext

Security checks