Martin Pelak

Results 16 comments of Martin Pelak

Hi, I have created a new pull request. See #12331. It fixes some issues mentioned in this pull request.

Hi, I have created a new pull request. See #12331

Hi, I am facing exactly the same problem, connector and task are in "RUNNING" state but no data is sent to ElasticSearch. I described my problem here https://forum.confluent.io/t/elasticsearch-sink-connector-unrecoverable-exception/1927/4 (v11.0.4). (There...

The same problem is described here https://github.com/confluentinc/kafka-connect-elasticsearch/issues/534

In order for me to [override](https://docs.confluent.io/platform/current/connect/references/allconfigs.html#override-the-worker-configuration) `max.poll.interval.ms`, I had to add `connector.client.config.override.policy=All` into `connect-standalone.properties` and `consumer.override.max.poll.interval.ms` into the plugin properties file.

Thank you for your help, I really appreciate it. ``` $ ./jmh-benchmarks/jmh.sh FileRecordsBenchmark Benchmark Mode Cnt Score Error Units FileRecordsBenchmark.testOpenChannelAfter thrpt 25 0.333 ▒ 0.004 ops/ms FileRecordsBenchmark.testOpenChannelBefore thrpt 25 0.001...

@divijvaidya, thank you for your help. JDK 17 and Scala 2.13 build and tests finished successfully. Can we now request a committer for review on this PR?

@divijvaidya thank you for your help. I updated the summary of the PR.

I also had a problem with Kraft which did not start on Windows. The latest commit https://github.com/apache/kafka/pull/12331/commits/f7cc920771735576d9cfba2afe6f26fdcfb2ccd4 fixes it. The commit https://github.com/apache/kafka/pull/12331/commits/77ae23d816ea1a30a3ec970b7dfe77fd35f7fe00 most likely fixes [KAFKA-7575](https://issues.apache.org/jira/browse/KAFKA-7575) and [KAFKA-2427](https://issues.apache.org/jira/browse/KAFKA-2427), but I...