Issues

• [Feature]: Add CollectingSinkAssert fluent assertions and size/isEmpty accessors to CollectingSink

  acceptedfeaturegood first issuejava
  Sekelenao/Flinkboot#256 · Filter by author Sekelenao opened on Oct 3, 2026 · 0.6.0-1.20
  2

  

• [Feature]: Enrich FlussSourceFactory with builder customizer overloads

  acceptedfeaturegood first issuejava
  Sekelenao/Flinkboot#252 · Filter by author Sekelenao opened on Oct 3, 2026 · 0.6.0-1.20

• [Feature]: Enrich FlussSinkFactory with builder customizer overloads

  acceptedfeaturegood first issuejava
  Sekelenao/Flinkboot#251 · Filter by author Sekelenao opened on Oct 3, 2026 · 0.6.0-1.20

• [Feature]: Add savepoints directory (state.savepoints.dir) configuration to job environment properties

  acceptedfeaturegood first issuejava
  Sekelenao/Flinkboot#250 · Filter by author Sekelenao opened on Oct 3, 2026 · 0.6.0-1.20

• [Refactor]: Remove deprecated RestoreMode.LEGACY to prevent state corruption and align with Flink 2.0

  acceptedgood first issuejava
  Sekelenao/Flinkboot#248 · Filter by author Sekelenao opened on Oct 3, 2026 · 0.6.0-1.20
  2

  

• [Bug]: StateBackendType.CHANGELOG causes runtime crash, should be a boolean flag enabling changelog state backend

  acceptedbuggood first issuejava
  Sekelenao/Flinkboot#247 · Filter by author Sekelenao opened on Oct 3, 2026 · 0.6.0-1.20

• [Refactor]: Relocate checkpoint storage configuration from StateBackendProperties to CheckpointingProperties

  acceptedgood first issuejava
  Sekelenao/Flinkboot#246 · Filter by author Sekelenao opened on Oct 3, 2026 · 0.6.0-1.20
  3

  

• [Bug]: Require both initial-backoff and max-backoff when either is configured in ExponentialDelayRestartProperties

  acceptedbuggood first issuejava
  Sekelenao/Flinkboot#245 · Filter by author Sekelenao opened on Oct 3, 2026 · 0.6.0-1.20
  2

  

• [Bug]: Reject incompatible checkpointing concurrency (min-pause with max-concurrent-checkpoints > 1)

  acceptedbuggood first issuejava
  Sekelenao/Flinkboot#244 · Filter by author Sekelenao opened on Oct 3, 2026 · 0.6.0-1.20
  2

  

• [Refactor]: Align LocalWebUiProperties.enabled with architectural guidelines

  acceptedgood first issuejava
  Sekelenao/Flinkboot#242 · Filter by author Sekelenao opened on Oct 3, 2026 · 0.6.0-1.20
  

• [Bug]: Fix property path in validation error messages in StateBackendPropertiesValidator and RestartStrategyPropertiesValidator

  acceptedbuggood first issuejava
  Sekelenao/Flinkboot#241 · Filter by author Sekelenao opened on Oct 3, 2026 · 0.6.0-1.20

• [Feature]: Add native partition subscription mode (partitions) to KafkaSourceProperties

  acceptedfeaturejava
  Sekelenao/Flinkboot#239 · Filter by author Sekelenao opened on Oct 3, 2026 · 0.6.0-1.20

• [Feature]: Add client-id-prefix configuration to KafkaSourceProperties

  acceptedfeaturegood first issuejava
  Sekelenao/Flinkboot#238 · Filter by author Sekelenao opened on Oct 3, 2026 · 0.6.0-1.20

• [Feature]: Enrich KafkaSinkFactory with SerializationSchema and schema customizer overloads

  acceptedfeaturejava
  Sekelenao/Flinkboot#230 · Filter by author Sekelenao opened on Oct 3, 2026 · 0.6.0-1.20

• [Feature]: Add JDBC Sink connector module (flinkboot-jdbc)

  draftfeaturejava
  Sekelenao/Flinkboot#229 · Filter by author Sekelenao opened on Sep 30, 2026

• [Feature]: Add Apache Iceberg Lakehouse connector module (flinkboot-iceberg)

  draftfeaturejava
  Sekelenao/Flinkboot#39 · Filter by author Sekelenao opened on Aug 26, 2026

• [Feature]: Add Apache Paimon Lakehouse connector module (flinkboot-paimon)

  draftfeaturejava
  Sekelenao/Flinkboot#30 · Filter by author Sekelenao opened on Aug 25, 2026