Re: Need Contributer Access (JIRAID- ganeshsahu)

Hi Ganesh, Your account is all set. Thank you. Luke On Fri, Mar 3, 2023 at 12:26 PM Ganesh S wrote: > Hello Team,i have got my JIRA ID created. > Would like to know if I need an additional contributor access to start > contributing. > I would appreciate it if you could inform me if yes. > >

AW: Problems with Kafka Connector Base classes

Hi Thanks a lot - it's clear now. Maybe the behavior of what happens if * no config is returned * more config > maxTasks is returned Can be added to API docu  http://localhost:8083/connectors?expand=info=status If here the task factory also reflects some "WAITING_FOR_TASK_CONFIG" - that

Re: [VOTE] KIP-882: Kafka Connect REST API timeout improvements

Hi Ashwin, Thanks for the feedback. I intentionally went with the choice of an unambiguous milliseconds unit and this would be clearly documented in the public Kafka Connect documentation. I think supporting multiple time units might lead to unnecessary confusion (what happens when no unit is

Re: [DISCUSS] KIP-882: Make Kafka Connect REST API request timeouts configurable

Hi Greg, Thanks for taking a look! 1. I believe Chris suggested the use of a query parameter above as we already have precedents for using query parameters to configure per request behavior in Kafka Connect (the restart connectors API and the get connectors API for instance). Also, the limited

Need Contributer Access (JIRAID- ganeshsahu)

Hello Team,i have got my JIRA ID created. Would like to know if I need an additional contributor access to start contributing. I would appreciate it if you could inform me if yes. My Jira ID : ganeshsahu Regards Ganesh

Jenkins build is unstable: Kafka » Kafka Branch Builder » trunk #1642

See

Build failed in Jenkins: Kafka » Kafka Branch Builder » trunk #1641

See Changes: -- [...truncated 447921 lines...] [2023-03-02T22:29:54.956Z] > Task :clients:compileTestJava UP-TO-DATE [2023-03-02T22:29:54.956Z] > Task :clients:testClasses

Build failed in Jenkins: Kafka » Kafka Branch Builder » trunk #1640

See Changes: -- [...truncated 450254 lines...] [2023-03-02T20:14:59.468Z] > Task :streams:test-utils:compileJava UP-TO-DATE [2023-03-02T20:14:59.468Z] > Task

Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.3 #160

See

Re: [DISCUSS] KIP-882: Make Kafka Connect REST API request timeouts configurable

Hey Yash, Thanks for the KIP, and sorry for the late review. 1. Have you considered a HTTP header to provide the client-configurable timeout? A header might more naturally extend to all of the other endpoints in the future, rather than duplicating the query parameter across endpoints. 2. I

Re: Problems with Kafka Connector Base classes

Hi Michael, The purpose of the Connector::taskConfigs method is to specify (implicitly) the number of tasks that need to be run for the connector, and (explicitly) how each task should be configured. The former is provided implicitly by the size of the list returned from that method; for each

Problems with Kafka Connector Base classes

Hi I'm using: org.apache.kafka:connect-api:3.4.0 I have a simple connector: == public class SimpleSinkConnector extends SinkConnector { @Override public List> taskConfigs(int maxTasks) { ArrayList> configs = new ArrayList<>(); for (int i = 0; i < maxTasks; i++) {

Re: [VOTE] KIP-907: Add Boolean Serde to public interface

+1 (non-binding) Thank you! On Wed, Mar 1, 2023 at 9:03 PM Matthias J. Sax wrote: > > +1 (binding) > > Thanks for the KIP! > > On 3/1/23 10:59 AM, Walker Carlson wrote: > > +1 Binding > > > > On Mon, Feb 27, 2023 at 1:46 PM Chia-Ping Tsai wrote: > > > >> +1 (binding) > >> > >

Re: [DISCUSS] KIP-902: Upgrade Zookeeper to 3.8.1

Thanks for the KIP. I think the following is a little confusing since it doesn't make it clear the the ZooKeeper deployment is separate from Kafka, Kafka only includes the ZooKeeper libraries. I think it would be useful to explain the upgrade process for someone running Apache Kafka 2.3 and

i have question to kafka error

hi~ i have question. i installed kafka in azure kubernetes services. but occur is error. -- error -- {"thread_name":"controller-event-thread","msg":"[ReplicaStateMachine controllerId=0] Triggering offline replica state changes","level":"INFO","time":"2023-02-27T00:09:39.590Z"}

[jira] [Created] (KAFKA-14774) the removed listeners should not be reconfigurable

Chia-Ping Tsai created KAFKA-14774: -- Summary: the removed listeners should not be reconfigurable Key: KAFKA-14774 URL: https://issues.apache.org/jira/browse/KAFKA-14774 Project: Kafka Issue

Jenkins build is unstable: Kafka » Kafka Branch Builder » trunk #1639

See

KAFKA-1194

Dear Community, I am currently using Apache kafka on Windows and I have stumbled upon the problem ".timeindex -> C:\Users\Administrator\Downloads\kafka\bin\windows\..\..\data\kafka\test1-3\.timeindex.deleted: The process cannot access the file because it is

Build failed in Jenkins: Kafka » Kafka Branch Builder » trunk #1638

See Changes: -- [...truncated 520943 lines...] [2023-03-02T11:24:25.472Z] Gradle Test Run :core:integrationTest > Gradle Test Executor 173 > KafkaZkClientTest >

[DISCUSS] KIP-910: Update Source offsets for Source Connectors without producing records

Hi All, I wanted to create a discussion thread for KIP-910: https://cwiki.apache.org/confluence/display/KAFKA/KIP-910%3A+Update+Source+offsets+for+Source+Connectors+without+producing+records Thanks! Sagar.

Build failed in Jenkins: Kafka » Kafka Branch Builder » trunk #1637

See Changes: -- [...truncated 538533 lines...] [2023-03-02T08:28:38.254Z] [2023-03-02T08:28:38.254Z] Gradle Test Run :core:integrationTest > Gradle Test Executor 175 >