Jenkins build became unstable: Kafka » Kafka Branch Builder » trunk #812

See

Re: [DISCUSS] KIP-819: Merge multiple KStreams in one operation

Hi all, Java permits the overload. Simple test class to demonstrate: ``` public class Test { private final String field; public Test(String field) { this.field = field; } public Test merge(Test that) { return new Test("Single-arg merge: " + this.field + ", " + th

Re: [DISCUSS] KIP-819: Merge multiple KStreams in one operation

I think Java does not allow to have both overloads, because it would result in ambiguity? If you call `s1.merge(s2)` it's unclear which method you want to call. -Matthias On 3/28/22 7:20 AM, Nick Telford wrote: Hi Matthias, How about instead of changing the signature of the existing method

Jenkins build is back to stable : Kafka » Kafka Branch Builder » trunk #811

See

Subscribe to Kafka dev mailing list

Subscribe to Kafka dev mailing list

[jira] [Created] (KAFKA-13774) AclAuthorizer should handle it a bit more gracefully if zookeeper.connect is null

Colin McCabe created KAFKA-13774: Summary: AclAuthorizer should handle it a bit more gracefully if zookeeper.connect is null Key: KAFKA-13774 URL: https://issues.apache.org/jira/browse/KAFKA-13774 Pro

Re: [DISCUSS] KIP-821: Connect Transforms support for nested structures

Hi Jorge, Thanks for addressing my comments; the KIP looks up-to-date and pretty readable now, and the rejected alternatives section does a great job of outlining the discussion so far and providing context for anyone else who might want to join in. 1. Thoughts on choice of delimiter: - I like th

Jenkins build became unstable: Kafka » Kafka Branch Builder » trunk #810

See

Re: [DISCUSS] KIP-821: Connect Transforms support for nested structures

Thanks, Chris! 1. I'd argue "this..field.child" could be harder to grasp than "this.field/child" + separator: "/". Even though this represents additional information, it follows a similar approach as the "Flatten#delimeter" configuration. I want to give the separator approach another try, so I hav

Jenkins build is unstable: Kafka » Kafka Branch Builder » 3.2 #10

See

Jenkins build is back to stable : Kafka » Kafka Branch Builder » trunk #809

See

Re: [DISCUSS] KIP-660: Pluggable ReplicaPlacer

Wondering about InvalidReplicationFactorException. Why would an implementation throw this? Given the information passed to the method, seems like this could only be thrown if there were obviously invalid arguments, like a negative number or zero. Can we just guarantee such invalid arguments aren't

[jira] [Resolved] (KAFKA-13600) Rebalances while streams is in degraded state can cause stores to be reassigned and restore from scratch

[ https://issues.apache.org/jira/browse/KAFKA-13600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-13600. --- Resolution: Fixed > Rebalances while streams is in degraded state can cause stores to be >

[jira] [Reopened] (KAFKA-13736) Flaky kafka.network.SocketServerTest.closingChannelWithBufferedReceives

[ https://issues.apache.org/jira/browse/KAFKA-13736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna reopened KAFKA-13736: --- > Flaky kafka.network.SocketServerTest.closingChannelWithBufferedReceives >

Re: [DISCUSS] KIP-819: Merge multiple KStreams in one operation

Hi Matthias, How about instead of changing the signature of the existing method to variadic, we simply add a new overload which takes variadic args: KStream merge(KStream first, KStream... rest); That way, we maintain both source *and* binary compatibility for the existing method, and we can enf

Kafka Streams Issue

Hi All, We are experiencing some weird behaviour with our interactive query service implementation. This is the flow we’ve implemented: 1. kafkaStreams.queryMetadataForKey(store, key, serializer) returns for activeHost HostInfo{host='localhost', port=8562}, and standbyHosts [] for the stor

[jira] [Created] (KAFKA-13773) Data loss after recovery from crash due to full hard disk

Tm Alkemade created KAFKA-13773: --- Summary: Data loss after recovery from crash due to full hard disk Key: KAFKA-13773 URL: https://issues.apache.org/jira/browse/KAFKA-13773 Project: Kafka Issue

[jira] [Resolved] (KAFKA-13736) Flaky kafka.network.SocketServerTest.closingChannelWithBufferedReceives

[ https://issues.apache.org/jira/browse/KAFKA-13736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-13736. --- Resolution: Fixed > Flaky kafka.network.SocketServerTest.closingChannelWithBufferedReceives

[jira] [Resolved] (KAFKA-13735) Flaky kafka.network.SocketServerTest.remoteCloseWithoutBufferedReceives

[ https://issues.apache.org/jira/browse/KAFKA-13735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-13735. --- Resolution: Fixed > Flaky kafka.network.SocketServerTest.remoteCloseWithoutBufferedReceives

Re: [VOTE] KIP-824 Allowing dumping segmentlogs limiting the batches in the output

hi guys again, How does it work now? After voting, should I update/modify the KIP? So basically is there any action I should do from my side? Thanks! On Sat, 26 Mar 2022 at 14:58, John Roesler wrote: > Thanks for the KIP, Sergio! > > I’m +1 (binding) > > Thanks, > John > > On Sat, Mar 26, 2022

Re: [DISCUSS] KIP-651 - Support PEM format for SSL certificates and

Thanks everyone. Good to know that Java 18 will have password-less keystore, so we can support this for other formats too in future. Looks like we are in agreement that it is reasonable to relax the requirement for PEM files now. Regards, Rajini On Thu, Mar 24, 2022 at 2:41 PM David Jacot wrote