2.1.37 (2024-09-20)
Merged pull requests:
2.1.36 (2024-08-27)
Merged pull requests:
2.1.35 (2024-08-17)
Merged pull requests:
2.1.34 (2024-06-22)
Merged pull requests:
- [pre-commit.ci] pre-commit autoupdate #212 (pre-commit-ci)
2.1.33 (2024-03-31)
Merged pull requests:
2.1.32 (2024-02-27)
Merged pull requests:
- I2392 #209 (Debashisa)
- I2392 #208 (Debashisa)
- updated code to serialize headers and timestamp as part of records #207 (Debashisa)
- I2400 #206 (stevehu)
- syncing consumer reocrd header type with producer record header type #205 (Debashisa)
- fixed test case #204 (Debashisa)
- I2428 #203 (Debashisa)
- I2365 #202 (Debashisa)
- [pre-commit.ci] pre-commit autoupdate #201 (pre-commit-ci)
- fixes #199 add pre-commit hook and apply it #200 (stevehu)
- fixes #197 Use NoneDecryptedInstance to load the config for registerM… #198 (stevehu)
- added the headers and timestamp on producer record #196 (Debashisa)
- added code for batchRollbackThreshold #195 (Debashisa)
2.1.31 (2024-01-16)
Merged pull requests:
- fixes #193 add timestamp to the CosumerRecord class #194 (stevehu)
- fixes #191 Output an error message in the log if SidecarProducer cann… #192 (stevehu)
2.1.30 (2023-11-21)
Merged pull requests:
2.1.29 (2023-11-19)
Merged pull requests:
2.1.28 (2023-10-24)
Merged pull requests:
2.1.27 (2023-10-04)
Merged pull requests:
2.1.26 (2023-08-17)
Merged pull requests:
2.1.25 (2023-08-08)
Merged pull requests:
2.1.24 (2023-08-07)
Merged pull requests:
2.1.23 (2023-07-11)
Merged pull requests:
2.1.22 (2023-06-22)
Merged pull requests:
2.1.21 (2023-06-22)
Merged pull requests:
2.1.20 (2023-06-17)
Merged pull requests:
2.1.19 (2023-06-05)
Merged pull requests:
2.1.18 (2023-05-06)
Merged pull requests:
2.1.17 (2023-05-05)
Merged pull requests:
2.1.16 (2023-04-28)
Merged pull requests:
2.1.15 (2023-04-19)
Merged pull requests:
2.1.14 (2023-04-19)
Merged pull requests:
2.1.13 (2023-04-19)
Merged pull requests:
2.1.12 (2023-04-14)
Merged pull requests:
2.1.11 (2023-04-10)
Merged pull requests:
2.1.10 (2023-04-06)
Merged pull requests:
2.1.9 (2023-03-30)
Merged pull requests:
2.1.8 (2023-03-06)
Merged pull requests:
2.1.7 (2023-02-14)
Merged pull requests:
- adding fields to topic replay metadata #172 (Debashisa)
- I1800 #171 (Debashisa)
- I1800 #170 (Debashisa)
2.1.6 (2023-02-06)
Merged pull requests:
2.1.5 (2023-01-04)
Merged pull requests:
2.1.4 (2022-11-30)
Merged pull requests:
2.1.3 (2022-11-10)
Merged pull requests:
2.1.2 (2022-10-22)
Merged pull requests:
- Enhanced error and log line for schema serialization failure #167 (Debashisa)
- I1488 #166 (Debashisa)
- fixes #164 upgrade confluent to 7.2.1 to match the 3.2.0 kafka verison #165 (stevehu)
- I1488 #163 (Debashisa)
- fixes #159 fixed a bug that not return the request status in ProduceR… #160 (stevehu)
- updated seek to offset utility fix #158 (Debashisa)
- fixes #156 update ProduceResponse to remove the ws.rs dependency #157 (stevehu)
2.1.1 (2022-04-26)
Merged pull requests:
- fixes #151 Move some of the common methods to KafkaConsumerManager #152 (stevehu)
- fixes #149 Move the produce code to the SidecarProducer for sharing #150 (stevehu)
- Consumer seek fix #148 (Debashisa)
- Fin ack fix #147 (Debashisa)
- adding exception stack trace to log line #146 (Debashisa)
- Generic fix for grabbing all from readkeyvaluestore #145 (KalevGonvick)
- updated code for health check fix #144 (Debashisa)
- Feature/light stream common functions #143 (KalevGonvick)
2.1.0 (2022-02-27)
Merged pull requests:
- fixes #141 retry seek as we might have illegal state exception during… #142 (stevehu)
- updated logic to handle IllegalStateException while seeking to offset #140 (Debashisa)
- fixes #138 search the consumerRecords to find other rollback points #139 (stevehu)
- fixes #136 output trace log in the seek method in the KafkaConsumerState #137 (stevehu)
- updated consumer state for dqueue check #135 (Debashisa)
- fixes #133 populate the correlationId into the headerMap for consumer #134 (stevehu)
- Issue131 #132 (stevehu)
- fixes #129 Clear the consumerRecords if seek is called in the KafkaCo… #130 (stevehu)
- fixes #127 Update ProduceRecord and SerializedKeyAndValue to add trac… #128 (stevehu)
- fixes #125 update the SchemaManagerImpl to remove the format present … #126 (stevehu)
- fixes #123 update kafka-consumer.yml and kafka-producer.yml for the a… #124 (stevehu)
- fixes #121 update the kafka-producer.yml and kafka-consumer.yml #122 (stevehu)
- fixes #119 add schema registry auto register schemas to true by default #120 (stevehu)
- fixes #117 remove schema registry config class and config file #118 (stevehu)
2.0.32 (2021-10-19)
Merged pull requests:
- fixes #115 remove the customized deserilizer serializer and add share… #116 (stevehu)
- add timestamp to RecordProcessResult for audit purpose #114 (GavinChenYan)
- fixes #112 upgrade to kafka 2.8.0 confluent 6.2.1 and avro 1.10.2 in … #113 (stevehu)
- fixes #109 add default method to the interface for module registry #110 (stevehu)
- fixes #107 add kafka-streams-avro-serde to the kafka-streams dependency #108 (stevehu)
- change produceResult model for dql producer endpoint #106 (GavinChenYan)
2.0.31 (2021-09-22)
Merged pull requests:
- fixes #104 Sync the max.poll.interval.ms to instanceTimeoutMs if latt… #105 (stevehu)
- fixes #102, implement new endpoint #103 (GavinChenYan)
- fixes #100 remove the kafka server dependency and add a workaround #101 (stevehu)
- dlq implementation for kafka sidecar refactoring #99 (GavinChenYan)
- model and config change for kafka-sidecar issue 19 implementation #98 (GavinChenYan)
- fixes #96 add correlationId, traceabilityId and key to the RecordProc… #97 (stevehu)
- Issue94 #95 (GavinChenYan)
- fixes #92 update the kafka-streams.yml format to separate Kafka prope… #93 (stevehu)
- fixes #90 update sidecar producer to use config serializer #91 (stevehu)
- fixes #88 Treat binary key as byte array instead of string in sync wi… #89 (stevehu)
- fixes #86 Missing break in the value format switch in the KafkaConsum… #87 (stevehu)
- fixes #84 Initialize schema coverters and use them based on the confi… #85 (stevehu)
2.0.30 (2021-08-23)
Merged pull requests:
- fixes #82 update the kafka-producer.yml and kafka-consumer.yml based … #83 (stevehu)
- fixes #78 update consumer record to alllow key and value have differe… #81 (stevehu)
- fixes #79 add default key and value formats configuration for produce… #80 (stevehu)
- fixes #76 add kafka-streams to the dependency for parent and kafka-st… #77 (stevehu)
- fixes #74 Make KafkaConsumerReadTask public and expose exception public #75 (stevehu)
- fixes #72 Add KafkaAdminConfig for Kafka client admin configuration #73 (stevehu)
2.0.29 (2021-07-25)
Merged pull requests:
2.0.28 (2021-06-27)
Merged pull requests:
- Issue67 #68 (stevehu)
- fixes #65 fix a warning in the producer pom.xml #66 (stevehu)
- fix the build issue #64 (chenyan71)
- fixes #62 sync the test config file kafka-consumer.yml and kafka-prod… #63 (stevehu)
2.0.27 (2021-05-25)
Merged pull requests:
- fixes #60 move producer entities to the kafka-entity module #61 (stevehu)
- fixes #58 support tls connection to the schema-registry #59 (stevehu)
- fixes #56 add a test case to serialize the ProduceRequest into a JSON #57 (stevehu)
- fixes #54 Allow the consumer with Avro schema to use NoWrapping conve… #55 (stevehu)
- fixes #52 add deadLetterEnabled flag to the kafka-consumer.yml #53 (stevehu)
- fixes #50 exclude conflict dependencies from kafka-avro-serializer #51 (stevehu)
- fixes #48 update consumer and producer config to support dead letter … #49 (stevehu)
2.0.26 (2021-04-27)
Merged pull requests:
- fixes #46 add backendApiHost and backendApiPath to kafka-consumer.yml #47 (stevehu)
- fixes #44 add kafka ConsumerRecord header to the response #45 (stevehu)
- fixes #42 add sync method to commit all current offsets #43 (stevehu)
- fixes #40 make the producer schema registry url configurable in the k… #41 (stevehu)
- fixes #38 update json property for ProduceRequest and allow NoSchemaR… #39 (stevehu)
- fixes #36 resolve the javadoc issues #37 (stevehu)
- fixes #34 only overwrite the group.id if it does not exsit in the kaf… #35 (stevehu)
- fixes #32 support keyFormat and valueFormat for reactive consumer opt… #33 (stevehu)
- fixes #30 update the producer and consumer config to support all Kafk… #31 (stevehu)
- Kafka mesh #29 (stevehu)
2.0.25 (2021-03-28)
Merged pull requests:
2.0.24 (2021-02-24)
Merged pull requests:
- Bump version.jackson from 2.10.4 to 2.12.1 #27 (dependabot)
- fixes #25 throw RuntimeException when Kafka is down #26 (stevehu)
- Enable idempotence for producer https://github.com/networknt/light-ka… #23 (stevehu)
2.0.23 (2021-01-29)
Merged pull requests:
- fixes #20 make the consumer public so that it can be accessed from an… #21 (stevehu)
- fixes #18 add more producer and consumer implementations #19 (stevehu)
2.0.22 (2020-12-22)
Merged pull requests:
- fixes #16 add config dependency to the kafka-common #17 (stevehu)
- fixes #14 add kafka headers to the producer record for security, trac… #15 (stevehu)
2.0.21 (2020-11-25)
Merged pull requests:
2.0.20 (2020-11-05)
Merged pull requests:
2.0.19 (2020-11-01)
Merged pull requests:
2.0.18 (2020-10-01)
Merged pull requests:
2.0.17 (2020-08-28)
Merged pull requests: