Re: [DISCUSS] KIP-474: To deprecate WindowStore#put(key, value)

Hi Omkar, Thanks for the KIP. However, discussion thread should include a link to the KIP document. Since you omitted it, here is the link. https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=115526545 As far as I understand, the point of the KIP is the current API can result in

Re: [DISCUSS] KIP-401 TransformerSupplier/ProcessorSupplier enhancements

It wasn't much of a lift changing option B to work for option C, so I closed that PR and made a new one, which should be identical to the KIP right now: https://github.com/apache/kafka/pull/6824. There are a few todos still which I will hold off until the KIP is accepted. I created a voting

Re: [VOTE] KIP-401: TransformerSupplier/ProcessorSupplier StateStore connecting

I spoke too early a month ago, but I believe the proposal is finalized now and ready for voting. KIP: https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=97553756 Discussion:

[jira] [Resolved] (KAFKA-8437) Consumer should wait for api version before checking if offset validation is possible

[ https://issues.apache.org/jira/browse/KAFKA-8437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-8437. Resolution: Fixed > Consumer should wait for api version before checking if offset

Build failed in Jenkins: kafka-2.3-jdk8 #18

See Changes: [jason] KAFKA-8437; Await node api versions before checking if offset validation [wangguoz] KAFKA-8219: add doc changes for static membership release (#6790) --

[jira] [Created] (KAFKA-8437) Consumer should wait for api version before checking if offset validation is possible

Jason Gustafson created KAFKA-8437: -- Summary: Consumer should wait for api version before checking if offset validation is possible Key: KAFKA-8437 URL: https://issues.apache.org/jira/browse/KAFKA-8437

[jira] [Resolved] (KAFKA-8219) Add web documentation for static membership

[ https://issues.apache.org/jira/browse/KAFKA-8219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-8219. Resolution: Fixed > Add web documentation for static membership >

About Error in Kafka 0.9

Hi Dev, Sorry to bother you, we use Kafka as MQ tools, the version is 0.9.0.1, now there have some error: 1. [kafka-producer-network-thread | producer-1] ERROR o.a.k.c.producer.internals.Sender -Uncaught error in kafka producer I/O thread: java.lang.IllegalStateException:

Configuring post webhook from BitBucket to Kafka REST Proxy?

Hello, Can anyone please help me out with this - https://stackoverflow.com/questions/56314662/how-to-configure-post-webhook-from-bitbucket-to-kafka-rest-proxy ? P.S. - Please do let me know if you need any further clarifications from me. Thanks -- *Thanks,* *Aryak Sengupta,* *Hyland

Build failed in Jenkins: kafka-trunk-jdk8 #3678

See Changes: [github] KAFKA-8437; Await node api versions before checking if offset validation [wangguoz] KAFKA-8219: add doc changes for static membership release (#6790)

[jira] [Created] (KAFKA-8438) Add API to allow user to define end behavior of consumer failure

Richard Yu created KAFKA-8438: - Summary: Add API to allow user to define end behavior of consumer failure Key: KAFKA-8438 URL: https://issues.apache.org/jira/browse/KAFKA-8438 Project: Kafka

[jira] [Created] (KAFKA-8435) Replace DeleteGroups request/response with automated protocol

Boyang Chen created KAFKA-8435: -- Summary: Replace DeleteGroups request/response with automated protocol Key: KAFKA-8435 URL: https://issues.apache.org/jira/browse/KAFKA-8435 Project: Kafka

[jira] [Created] (KAFKA-8436) Replace AddOffsetsToTxn request/response with automated protocol

Boyang Chen created KAFKA-8436: -- Summary: Replace AddOffsetsToTxn request/response with automated protocol Key: KAFKA-8436 URL: https://issues.apache.org/jira/browse/KAFKA-8436 Project: Kafka