Build failed in Jenkins: kafka-trunk-jdk11 #864

See Changes: [matthias] KAFKA-7245: Deprecate WindowStore#put(key, value) (#7105) -- [...truncated 5.42 MB...] org.apache.kafka.streams.MockProcessorContextTest >

Build failed in Jenkins: kafka-2.4-jdk8 #3

See Changes: [matthias] MINOR: Modified Exception handling for KIP-470 (#7461) -- [...truncated 2.91 MB...] org.apache.kafka.streams.TopologyTestDriverTest >

Re: [VOTE] KIP-527: Add VoidSerde to Serdes

Hello, Guozhang. Following added to the KIP: > If not null parameters passed then an java.lang.IllegalArgumentException will > be thrown. В Пн, 07/10/2019 в 15:51 -0700, Guozhang Wang пишет: > Hello Nikolay, > > Could you clarify in the wiki doc what would happen if the passed in > `byte[]

Re: [DISCUSS] Apache Kafka 2.4.0 release

Hi Manikumar, It is technically true that KIP-471 is not completed, but the only aspect that is not there are merely two metrics that I could not add due to the RocksDB version currently used in Streams. Adding those two metrics once the RocksDB version will have been increased, will be a minor

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

See Changes: [matthias] MINOR: Modified Exception handling for KIP-470 (#7461) -- [...truncated 2.68 MB...] org.apache.kafka.streams.test.ConsumerRecordFactoryTest >

[jira] [Created] (KAFKA-8996) Support health check method of TransactionManager and KafkaProducer

Myeonghyeon Lee created KAFKA-8996: -- Summary: Support health check method of TransactionManager and KafkaProducer Key: KAFKA-8996 URL: https://issues.apache.org/jira/browse/KAFKA-8996 Project: Kafka

[jira] [Created] (KAFKA-8997) Make Errors a first class type in the auto-generated protocol

David Jacot created KAFKA-8997: -- Summary: Make Errors a first class type in the auto-generated protocol Key: KAFKA-8997 URL: https://issues.apache.org/jira/browse/KAFKA-8997 Project: Kafka

[jira] [Created] (KAFKA-8998) Release Candidate Version 2.3.1-rc1 breaks backward compatibility in PATCH version

Juan Pablo Correa created KAFKA-8998: Summary: Release Candidate Version 2.3.1-rc1 breaks backward compatibility in PATCH version Key: KAFKA-8998 URL: https://issues.apache.org/jira/browse/KAFKA-8998

Need some clarification of Kafka and MQTT

Hi, We are building some IoT driven solution for industries, I am very new to Kafka and I need some clarifications so please help me out with below given doubts. We have use case where we wanted to connect Kafka with MQTT as source of receiving data, But I am little bit confused on this. I saw

Build failed in Jenkins: kafka-trunk-jdk11 #865

See Changes: [matthias] MINOR: Modified Exception handling for KIP-470 (#7461) -- [...truncated 5.42 MB...] org.apache.kafka.streams.test.OutputVerifierTest >

Re: [DISCUSS] Apache Kafka 2.4.0 release

Thanks Bruno. We will mark KIP-471 as complete. On Tue, Oct 8, 2019 at 2:39 PM Bruno Cadonna wrote: > Hi Manikumar, > > It is technically true that KIP-471 is not completed, but the only > aspect that is not there are merely two metrics that I could not add > due to the RocksDB version

[jira] [Resolved] (KAFKA-8983) AdminClient deleteRecords should not fail all partitions unnecessarily

[ https://issues.apache.org/jira/browse/KAFKA-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-8983. Fix Version/s: 2.4.0 Resolution: Fixed > AdminClient deleteRecords should not fail

[jira] [Created] (KAFKA-8999) org.apache.kafka.common.utils.Utils.delete masks errors encountered during processing

Stefan Hoffmeister created KAFKA-8999: - Summary: org.apache.kafka.common.utils.Utils.delete masks errors encountered during processing Key: KAFKA-8999 URL: https://issues.apache.org/jira/browse/KAFKA-8999

Build failed in Jenkins: kafka-trunk-jdk11 #866

See Changes: [github] KAFKA-8983; AdminClient deleteRecords should not fail all partitions -- [...truncated 2.68 MB...] org.apache.kafka.streams.TopologyTestDriverTest >

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

See Changes: [github] KAFKA-8983; AdminClient deleteRecords should not fail all partitions -- [...truncated 2.68 MB...] org.apache.kafka.streams.test.TestRecordTest >

[jira] [Created] (KAFKA-9003) Flaky Test RepartitionOptimizingIntegrationTest#shouldSendCorrectRecords_OPTIMIZED

Sophie Blee-Goldman created KAFKA-9003: -- Summary: Flaky Test RepartitionOptimizingIntegrationTest#shouldSendCorrectRecords_OPTIMIZED Key: KAFKA-9003 URL: https://issues.apache.org/jira/browse/KAFKA-9003

Re: [VOTE] KIP-527: Add VoidSerde to Serdes

Thanks, I'm +1 (binding). On Tue, Oct 8, 2019 at 2:33 AM Nikolay Izhikov wrote: > Hello, Guozhang. > > Following added to the KIP: > > > If not null parameters passed then an java.lang.IllegalArgumentException > will be thrown. > > В Пн, 07/10/2019 в 15:51 -0700, Guozhang Wang пишет: > > Hello

[jira] [Created] (KAFKA-9001) Flaky Test KStreamAggregationIntegrationTest#shouldReduceSessionWindows

Sophie Blee-Goldman created KAFKA-9001: -- Summary: Flaky Test KStreamAggregationIntegrationTest#shouldReduceSessionWindows Key: KAFKA-9001 URL: https://issues.apache.org/jira/browse/KAFKA-9001

[jira] [Resolved] (KAFKA-7190) Under low traffic conditions purging repartition topics cause WARN statements about UNKNOWN_PRODUCER_ID

[ https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7190. Fix Version/s: 2.4.0 Assignee: Bob Barrett (was: Guozhang Wang)

[jira] [Created] (KAFKA-9000) Flaky Test KTableKTableForeignKeyJoinIntegrationTest.doLeftJoinFromRightThenDeleteRightEntity

Bruno Cadonna created KAFKA-9000: Summary: Flaky Test KTableKTableForeignKeyJoinIntegrationTest.doLeftJoinFromRightThenDeleteRightEntity Key: KAFKA-9000 URL: https://issues.apache.org/jira/browse/KAFKA-9000

[jira] [Created] (KAFKA-9002) org.apache.kafka.streams.integration.RegexSourceIntegrationTest.testRegexMatchesTopicsAWhenCreated

Bill Bejeck created KAFKA-9002: -- Summary: org.apache.kafka.streams.integration.RegexSourceIntegrationTest.testRegexMatchesTopicsAWhenCreated Key: KAFKA-9002 URL: https://issues.apache.org/jira/browse/KAFKA-9002

Build failed in Jenkins: kafka-2.4-jdk8 #4

See Changes: [jason] KAFKA-8983; AdminClient deleteRecords should not fail all partitions [jason] KAFKA-7190; Retain producer state until transactionalIdExpiration time --

Re: [DISCUSS] KIP-448: Add State Stores Unit Test Support to Kafka Streams Test Utils

Hi, I am currently switching between jobs - so slightly busier than usual. But I will definitely update this KIP during the weekend. Thanks, Yishun On Mon, Oct 7, 2019 at 3:18 PM Matthias J. Sax wrote: > > What is the status of this KIP? Any updates? > > > -Matthias > > > On 9/10/19 8:08 PM,

Build failed in Jenkins: kafka-trunk-jdk11 #867

See Changes: [jason] KAFKA-7190; Retain producer state until transactionalIdExpiration time -- [...truncated 2.68 MB...]

[jira] [Created] (KAFKA-9004) Fetch from follower unintentionally enabled for old consumers

Jason Gustafson created KAFKA-9004: -- Summary: Fetch from follower unintentionally enabled for old consumers Key: KAFKA-9004 URL: https://issues.apache.org/jira/browse/KAFKA-9004 Project: Kafka

[jira] [Resolved] (KAFKA-8944) Compiler Warning

[ https://issues.apache.org/jira/browse/KAFKA-8944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8944. Resolution: Fixed > Compiler Warning > > > Key: KAFKA-8944 >

Re: Need some clarification of Kafka and MQTT

No, you needs something that can speak mqtt and sent that data to kafka (and possibly the other way around). There are many such alternatives but kafka knows nothing about mqtt Den tis 8 okt. 2019 kl 18:01 skrev Sarvesh Gupta : > Hi, > > We are building some IoT driven solution for industries, I