siddhi-io siddhi-io-kafka issues

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

issues

Newest

Newest Most commented Recently updated Oldest Least commented Least recently updated

Bump commons-io:commons-io from 2.5 to 2.14.0

#164 dependabot[bot] opened 2 months ago
0
Bump com.google.protobuf:protobuf-java from 3.17.3 to 3.25.5

#163 dependabot[bot] opened 2 months ago
0
Fix duplicate event issue when data flow is slow

#162 rmsamitha closed 1 year ago
1
Fix test failure for #159

#161 Allan-QLB opened 1 year ago
0
Revert "Add error log when KafkaConsumerThread terminate unexpectedly"

#160 AnuGayan closed 1 year ago
0
Add error log when KafkaConsumerThread terminate unexpectedly

#159 Allan-QLB closed 1 year ago
0
Bump jackson-databind from 2.13.3 to 2.13.4.1

#158 dependabot[bot] opened 2 years ago
0
Private package com.google.

#157 AnuGayan closed 2 years ago
0
Bump protobuf-java from 3.17.3 to 3.19.6

#156 dependabot[bot] closed 2 months ago
1
Allow Avro deserialising via Schema Registry

#155 lasanthaS closed 2 years ago
0
Add log4j1 as a test dependency

#154 AnuGayan closed 2 years ago
0
Remove kafka dependencies

#153 lasanthaS closed 2 years ago
0
Bump text mapper version

#152 lasanthaS closed 2 years ago
0
Bump jackson-databind from 2.9.8 to 2.9.10.8

#151 dependabot[bot] closed 2 years ago
1
Upgrade log4j1 to 2.17.1

#150 dnwick closed 2 years ago
0
Add support for message decoding via Schema registry

#149 lasanthaS closed 2 years ago
0
Kafka MirrorMaker 2.0 support for automatic failover

#148 Manasha11 opened 2 years ago
0
Bump siddhi version

#147 AnuGayan closed 3 years ago
0
Change repo URLs to https in pom.xml files of master

#146 senthuran16 closed 3 years ago
0
Add Kafka Sink Error Stream Test case

#145 dilini-muthumala closed 3 years ago
0
Send events to error handlers when broker is unavailable

#144 dilini-muthumala closed 3 years ago
0
[KafkaSink] Send events to error store when the broker is not available

#143 dilini-muthumala closed 3 years ago
0
Bump commons-io from 2.5 to 2.7

#142 dependabot[bot] closed 3 years ago
1
Add synchronous publishing

#141 ramindu90 closed 3 years ago
0
Fix for https://github.com/wso2/streaming-integrator/issues/179

#140 dilini-muthumala closed 3 years ago
0
Add Kafka Metrics into the ETL dashboard

#139 dilini-muthumala closed 3 years ago
1
Fix javadoc comment

#138 sybernix closed 3 years ago
0
System parameters cannot be defined for Sink and Source

#137 AnuGayan closed 2 years ago
1
Add support to read configurations from deployment yaml file

#136 AnuGayan closed 3 years ago
0
Add Kafka Metrics

#135 dilini-muthumala closed 3 years ago
0
Add Replay of Range of Events

#134 sybernix closed 3 years ago
0
Configuring the partition.no.list parameter.

#133 Gayanthakaushal opened 4 years ago
0
does support event type as protobuf for source kafka?

#132 gloriaok00 opened 4 years ago
0
Add trp properties

#131 ramindu90 closed 4 years ago
0
Double reading of events from Kafka topic when enable.offsets.commit = "false"

#130 xtrmstep opened 4 years ago
2
Bump zookeeper from 3.4.0 to 3.4.14

#129 dependabot[bot] closed 3 years ago
1
Bump the siddhi version to 5.1.13

#128 sahandilshan closed 4 years ago
0
Error in Siddhi tooling 5.1.2 in Docker when application stopped and started again

#127 xtrmstep opened 4 years ago
1
Add sync and asyncronous committing configurable and bug fix for sending events after siddhi app undeployed

#126 ramindu90 closed 4 years ago
0
Support record transformation during consumption

#125 pcnfernando opened 4 years ago
0
Linking to the correct issue page in README

#124 vringar closed 4 years ago
5
Replace ScheduledExecutorService with ExecutorService

#123 sahandilshan closed 5 years ago
0
Check if consumerKafkaGroup is null before executing restoreState() method

#122 sahandilshan closed 5 years ago
0
Replace ScheduledExecutorService with ExecutorService

#121 sahandilshan closed 5 years ago
0
Support providing handle over committing the offset

#120 pcnfernando closed 5 years ago
0
Change the reference for adding kafka jars

#119 sahandilshan closed 5 years ago
0
Support enable/disable automatic committing

#118 pcnfernando closed 5 years ago
0
Relatively low consuming/publishing rates

#117 pcnfernando closed 5 years ago
3
Improve testcase assertion logic to avoid intermittent failures

#116 mohanvive closed 5 years ago
0
Update site and jar info

#115 suhothayan closed 5 years ago
0