- Add streamName to NatsJetStreamSourceBuilder #32 @miklosbarabas
- Revert to manual ack #33 @scottf
- Remove redundant NatSubjectStateSplitState class #35 @scottf
- fixes consumer 409 deleted #36 @tilakraj94
- assign all splits correctly to source readers #37 @tilakraj94
- Clear source reader state on checkpointing #39 @tilakraj94
- Add tests to demonstrate getting headers from the source message. #40 @scottf
- Add tests for NatsSubjectSplitReader class #43 @somratdutta
- Entire message as payload #44 @scottf
- Add tests for classes, add null checks #46 @somratdutta
- Example 2 #48 @scottf
- Generify NatsSourceEnumerator #49 @scottf
- Add Support for NATS Message Serialization/De-Serialization #50 @tilakraj94
- Add multiple messages to verify order #51 @tilakraj94
Contributors
scottf, miklosbarabas, and 2 other contributors