Qing

KAFKA-13817 Always sync nextTimeToEmit with wall clock

1

We should sync nextTimeToEmit with wall clock on each method call to ensure throttling works correctly in case of clock drift. If we dont, then in the event of significant...

[Flink 16024][Connector][JDBC] Support FilterPushdown

12

## What is the purpose of the change Implement Filter Pushdown in JDBC Connector Source, this is an optimization that will avoid scanning the whole table into Flink when we...

[Flink 14101][Connectors][Jdbc] SQL Server dialect

12

## What is the purpose of the change Support Microsoft SQL Server in JDBC connector ## Brief change log - Added SqlServerDialect and corresponding helper class ## Verifying this change...

KAFKA-13882 Docker to preview docs locally

5

I've added a Dockerfile and handy script to run documentation locally with 1 command. It should reduce friction for docs contribution.

Now we only support Double, we should try to support more number type, one possible way is to use a typeclass to capture the ability of `Double => X`, and...

`TakeOne::isFollowedBy` returns `Source[(Boolean, Source[Element])]` which the 1st param `Boolean` communicate whether the source is followed by a specific sequence or not, but it's not clear what does the 2nd element...