Jenkins build is back to normal : kafka-trunk-jdk8 #4111

See

Build failed in Jenkins: kafka-2.2-jdk8 #16

See Changes: [bbejeck] HOTFIX: bump system test versions (#7835) -- [...truncated 2.73 MB...] kafka.api.SaslClientsWithInvalidCredentialsTest > testManualAssignmentConsumer

[jira] [Created] (KAFKA-9312) KafkaProducer flush behavior does not guarantee send completion under record batch splitting

Lucas Bradstreet created KAFKA-9312: --- Summary: KafkaProducer flush behavior does not guarantee send completion under record batch splitting Key: KAFKA-9312 URL: https://issues.apache.org/jira/browse/KAFKA-9312

Re: [DISCUSS] KIP-158 UPDATED: Enable source connectors to create new topics with specific configs in Kafka Connect during runtime

Thanks Randall and Ryanne for your comments. I'm replying to them below, in order of appearance: To Randall's comments: 1) I assumed these properties would be visible to connectors, since by definition these are connector properties. I added a mention. However I'm not sure if you are also making

Re: Kafka Stream 2.3 DeserializationExceptionHandler issue !

Not sure about the first issue you report, however, in general this may indicate a user error (but I am not 100% sure; might also be a bug): https://cwiki.apache.org/confluence/display/KAFKA/FAQ#FAQ-WhydoIgetanIllegalStateExceptionwhenaccessingrecordmetadata? For the second issue, it might be a k

[jira] [Resolved] (KAFKA-9311) Jumbled table content for broker config doc

[ https://issues.apache.org/jira/browse/KAFKA-9311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sönke Liebau resolved KAFKA-9311. - Resolution: Not A Problem This is not an error but was a conscious change in KAFKA-8474 to improv

[jira] [Created] (KAFKA-9311) Jumbled table content for broker config doc

Joel Hamill created KAFKA-9311: -- Summary: Jumbled table content for broker config doc Key: KAFKA-9311 URL: https://issues.apache.org/jira/browse/KAFKA-9311 Project: Kafka Issue Type: Bug

Re: [VOTE] KIP-531: Drop support for Scala 2.11 in Kafka 2.5

+1 (binding), though there is definitely still some compatibility risk -- regardless of updates, people are going to have apps that may need other updates but upgrading between scala versions is still too painful for too long to warrant the effort to update. But in that case they probably aren't up

Jenkins build is back to normal : kafka-trunk-jdk11 #1027

See

Build failed in Jenkins: kafka-2.2-jdk8-old #197

See Changes: [bbejeck] HOTFIX: bump system test versions (#7835) -- Started by an SCM change Running as SYSTEM [EnvInject] - Loading node environment variables. Building

[jira] [Created] (KAFKA-9310) StreamThread may die from recoverable UnknownProducerId exception

John Roesler created KAFKA-9310: --- Summary: StreamThread may die from recoverable UnknownProducerId exception Key: KAFKA-9310 URL: https://issues.apache.org/jira/browse/KAFKA-9310 Project: Kafka

[jira] [Created] (KAFKA-9309) Add the ability to translate Message classes to and from JSON

Colin McCabe created KAFKA-9309: --- Summary: Add the ability to translate Message classes to and from JSON Key: KAFKA-9309 URL: https://issues.apache.org/jira/browse/KAFKA-9309 Project: Kafka Is

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

See Changes: [github] MINOR: Add compatibility tests for 2.4.0 (#7838) -- [...truncated 2.78 MB...] org.apache.kafka.streams.test.OutputVerifierTest > shouldFailIfValueI

Kafka Stream 2.3 DeserializationExceptionHandler issue !

Hi Team, Could you please help us out in 1 issue related to Kafka stream. - Os: Windows 10 - Kafka on windows 10 I am trying to utilize custom *DeserializationExceptionHandler *in Kafka Stream DSL 2.3, using 5 partition to test. - Scenario 1: Using Custom Serde(Processing guarantee:

Require information on kafka-monitor

HI Team, I would like to have more information on kafka-monitor. I am working on kafka smart monitoring dashboard , as mentioned in below link; where i require to deploy kafka-monitor. Since i am lacking knowledge for same, Can you help me for same. https://github.com/guilhemmarchand/telegraf-kaf

Re: Proposal for EmbeddedKafkaCluster: Support JUnit 5 Extension in addition to JUnit 4 Rule

Hi Tommy and Matthias, Thanks for the context! I can see that there are good reasons to want a supported, embedded Kafka cluster. If you want to propose to add one, I can help you navigate the process. Thanks, John On Tue, Dec 10, 2019, at 07:13, Matthias Merdes wrote: > Hi John and Thomas, >

Jenkins build is back to normal : kafka-trunk-jdk8 #4109

See

[jira] [Created] (KAFKA-9308) Misses SAN after certificate creation

Agostino Sarubbo created KAFKA-9308: --- Summary: Misses SAN after certificate creation Key: KAFKA-9308 URL: https://issues.apache.org/jira/browse/KAFKA-9308 Project: Kafka Issue Type: Bug

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

See Changes: [bbejeck] MINOR: Improve javadoc of user-customizable metrics API (#7810) [wangguoz] HOTFIX: remove non-os streams example repo reference from web docs [rajinisivaram] MINOR: Adjust `testClientDis