siddhi-io-kafka
siddhi-io-kafka copied to clipboard
siddhi-io
Extension that can be used to receive events from a Kafka cluster and to publish events to a Kafka cluster
## Purpose Fix test failure for #159 ## Goals Fix test failure for #159 ## Approach delete old submission of KafkaConsumerThread ## User stories ## Release note ## Documentation ##...
Bumps [jackson-databind](https://github.com/FasterXML/jackson) from 2.13.3 to 2.13.4.1. Commits See full diff in compare view [](https://docs.github.com/en/github/managing-security-vulnerabilities/about-dependabot-security-updates#about-compatibility-scores) Dependabot will resolve any conflicts with this PR as long as you don't alter...
![dependabot[bot] avatar](https://avatars.githubusercontent.com/in/29110?v=4 "dependabot[bot] avatar"){kind=avatar}
Bumps [protobuf-java](https://github.com/protocolbuffers/protobuf) from 3.17.3 to 3.19.6. Release notes Sourced from protobuf-java's releases. Protocol Buffers v3.19.6 Java Refactoring java full runtime to reuse sub-message builders and prepare to migrate parsing logic...
**Description:** When using MirrorMaker 2.0 in a multi region deployment, add support to automatically calculate the correct offset using RemoteClientUtil [1] in case it needs to failover to the target...
**Description:** In this document[1], it needs to corrected as "when did not configure the partition.no.list parameter the consumer subscribe to all the topics" The default value is not the "0"....
Hi Guys, May I inquire currently does support event type as protobuf for source kafka? I noticed doc said only "text","xml","binary","json" supported. Want to double comfirm. Thanks~
Hi, Very often I'm getting the following error while stopping and running again my Siddhi application in the tooling. Topic name doesn't matter. The error is disappearing after several stop/start...
Hi, Have tested Siddhi app and bumped into the issue with setting `enable.offsets.commit = "false"`. When it's set, the source may start reading same events twice duplicating them in the...
**Description:** It would be more efficient during consumption, if Siddhi Source is improved to be configured with transformations to make lightweight message-at-a-time modifications. For example, if there are 50 fields...
Bumps [com.google.protobuf:protobuf-java](https://github.com/protocolbuffers/protobuf) from 3.17.3 to 3.25.5. Release notes Sourced from com.google.protobuf:protobuf-java's releases. Protocol Buffers v3.20.3 Java Refactoring java full runtime to reuse sub-message builders and prepare to migrate parsing logic...