Tim Chan

I would like to have set ScanIndexForward to false in my Query. Is this possible?

setting wartremoverWarnings is creating errors instead of warnings

4

```scala wartremoverWarnings ++= Seq( Wart.Any, Wart.Any2StringAdd ) ``` is producing Inferred type containing Any [error] var result: Option[Any] = None

setting wartremoverExcluded to a scala file results in exclusion of all source files as well

3

wartremoverExcluded += baseDirectory.value / "target" / "scala-2.10" / "src_managed" / "main" / "com" / "acme" / "thrift" / "raw" / "UserAttribute.scala" results in... no warnings are reported when they were...

I'm getting this error after updating my M1 MacBook Pro to Mac OS X Ventura Beta. ``` We were unable to load KBFS (Fuse kext). This may be due to...

Multi-Cluster Support

6

Are there plans to support multiple Kafka clusters? We have a possible use case where our users may have streaming applications deployed to multiple Kafka instances. It would be a...

[QUESTION] How do I use a topic like a database table and query it as fast as I possibly can?

4

Using `offsets_for_times`, I'd like to be able to query all message between a certain time range, as fast as I can. Using the `confluent-kafka-python` client, I was able to do...

JsonScalaCodec JSON output is not what I expected

1

Example thrift struct ``` Scala struct Prediction { 10: i64 userId, 20: list rawPrediction, 30: list probability, 40: double prediction } ``` Set up code ``` Scala val pred =...

I added `kafka-connect-dynamodb` to my Kafka Connect nodes and get the following error when trying to create an s3 connector. ``` com.amazonaws.services.s3.AmazonS3ClientBuilder.withAccelerateModeEnabled(Ljava/lang/Boolean;)Lcom/amazonaws/services/s3/AmazonS3Builder; at io.confluent.connect.s3.storage.S3Storage.newS3Client(S3Storage.java:63) at io.confluent.connect.s3.storage.S3Storage.(S3Storage.java:59) ... 15 more ```...