[jira] [Created] (KAFKA-9375) Add thread names to kafka connect threads

karan kumar created KAFKA-9375: -- Summary: Add thread names to kafka connect threads Key: KAFKA-9375 URL: https://issues.apache.org/jira/browse/KAFKA-9375 Project: Kafka Issue Type: Improvement

[jira] [Resolved] (KAFKA-8135) Kafka Producer deadlocked on flush call with intermittent broker unavailability

[ https://issues.apache.org/jira/browse/KAFKA-8135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-8135. --- Resolution: Duplicate > Kafka Producer deadlocked on flush call with intermittent broker > u

Re: [DISCUSS] KIP-553: Enable TLSv1.3 by default and disable all protocols except [TLSV1.2, TLSV1.3]

Hi Nikolay, There a couple of things you could do: 1) Run all system tests that use SSL with TLSv1.3. I had run a subset, but it will be good to run all of them. You can do this locally using docker with JDK 11 by updating the files in tests/docker. You will need to update tests/kafkatest/service

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

See Changes: [wangguoz] HOTFIX: fix system test race condition (#7836) -- [...truncated 5.48 MB...] org.apache.kafka.streams.test.OutputVerifierTest > shouldFailIfValueIsD

[jira] [Created] (KAFKA-9376) Plugin class loader not found using MM2

Sinóros-Szabó Péter created KAFKA-9376: -- Summary: Plugin class loader not found using MM2 Key: KAFKA-9376 URL: https://issues.apache.org/jira/browse/KAFKA-9376 Project: Kafka Issue Type:

Re: Kafka 2.4.0 & Mirror Maker 2.0 Error

Hi, I just tested with 2.4.0 release, I still get the same error. Filed the jira ticket: https://issues.apache.org/jira/browse/KAFKA-9376 Thanks, Peter On Mon, 6 Jan 2020 at 21:26, Ryanne Dolan wrote: > I just downloaded the 2.4.0 release tarball and didn't run into any issues. > Peter, Jamie,

[jira] [Resolved] (KAFKA-9337) Simplifying standalone mm2-connect config

[ https://issues.apache.org/jira/browse/KAFKA-9337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison resolved KAFKA-9337. --- Fix Version/s: 2.5.0 Resolution: Fixed > Simplifying standalone mm2-connect config > -

[jira] [Created] (KAFKA-9377) Refactor StreamsPartitionAssignor Repartition Count logic

Boyang Chen created KAFKA-9377: -- Summary: Refactor StreamsPartitionAssignor Repartition Count logic Key: KAFKA-9377 URL: https://issues.apache.org/jira/browse/KAFKA-9377 Project: Kafka Issue Typ

[jira] [Created] (KAFKA-9378) Revisit the sub-topology initialization logic

Boyang Chen created KAFKA-9378: -- Summary: Revisit the sub-topology initialization logic Key: KAFKA-9378 URL: https://issues.apache.org/jira/browse/KAFKA-9378 Project: Kafka Issue Type: Improveme

[jira] [Resolved] (KAFKA-9330) Calling AdminClient.close in the AdminClient completion callback causes deadlock

[ https://issues.apache.org/jira/browse/KAFKA-9330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9330. Fix Version/s: 2.5.0 Resolution: Fixed > Calling AdminClient.close in the AdminClien

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

See Changes: [mimaison] KAFKA-9337: Simplify MirrorMaker2 sample config (#7872) -- [...truncated 2.78 MB...] org.apache.kafka.streams.TopologyTestDriverTest > shouldNot

[jira] [Created] (KAFKA-9379) Flaky Test TopicCommandWithAdminClientTest.testCreateAlterTopicWithRackAware

Matthias J. Sax created KAFKA-9379: -- Summary: Flaky Test TopicCommandWithAdminClientTest.testCreateAlterTopicWithRackAware Key: KAFKA-9379 URL: https://issues.apache.org/jira/browse/KAFKA-9379 Projec

[jira] [Resolved] (KAFKA-6614) kafka-streams to configure internal topics message.timestamp.type=CreateTime

[ https://issues.apache.org/jira/browse/KAFKA-6614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6614. Fix Version/s: 2.5.0 Resolution: Fixed > kafka-streams to configure internal topics

[jira] [Created] (KAFKA-9380) Do Not Accept Null Values in MemberAssignment Constructor

David Mollitor created KAFKA-9380: - Summary: Do Not Accept Null Values in MemberAssignment Constructor Key: KAFKA-9380 URL: https://issues.apache.org/jira/browse/KAFKA-9380 Project: Kafka Iss

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

See Changes: [jason] KAFKA-9330: Skip `join` when `AdminClient.close` is called in callback -- [...truncated 2.78 MB...] org.apache.kafka.streams.TestTopicsTest > testDu

[jira] [Created] (KAFKA-9381) kafka-streams-scala: Javadocs + Scaladocs not published on maven central

Julien Jean Paul Sirocchi created KAFKA-9381: Summary: kafka-streams-scala: Javadocs + Scaladocs not published on maven central Key: KAFKA-9381 URL: https://issues.apache.org/jira/browse/KAFKA-9381

[jira] [Resolved] (KAFKA-9335) java.lang.IllegalArgumentException: Number of partitions must be at least 1.

[ https://issues.apache.org/jira/browse/KAFKA-9335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-9335. -- Resolution: Fixed > java.lang.IllegalArgumentException: Number of partitions must be at least 1

[jira] [Resolved] (KAFKA-9065) Loading offsets and group metadata loops forever

[ https://issues.apache.org/jira/browse/KAFKA-9065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9065. Fix Version/s: 2.4.1 Resolution: Fixed > Loading offsets and group metadata loops fo

[jira] [Created] (KAFKA-9382) Allow consumers to commit offset in the middle of a rebalance

Guozhang Wang created KAFKA-9382: Summary: Allow consumers to commit offset in the middle of a rebalance Key: KAFKA-9382 URL: https://issues.apache.org/jira/browse/KAFKA-9382 Project: Kafka

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

See

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

See Changes: [jason] KAFKA-9330: Skip `join` when `AdminClient.close` is called in callback [matthias] KAFKA-6614: configure internal topics with -- [...truncated 5.66

[jira] [Created] (KAFKA-9383) Expose Consumer Group Metadata for Transactional Producer

Boyang Chen created KAFKA-9383: -- Summary: Expose Consumer Group Metadata for Transactional Producer Key: KAFKA-9383 URL: https://issues.apache.org/jira/browse/KAFKA-9383 Project: Kafka Issue Typ

[jira] [Created] (KAFKA-9384) Loop improvements

highluck created KAFKA-9384: --- Summary: Loop improvements Key: KAFKA-9384 URL: https://issues.apache.org/jira/browse/KAFKA-9384 Project: Kafka Issue Type: Improvement Components: streams

Re: about default value of struct of connect api

hello guys, update my question, i made a test, code as below, i want to set a default value of address to person SchemaBuilder schemaBuilder = SchemaBuilder.struct().name("address") .field("province", SchemaBuilder.STRING_SCHEMA) .field("city", SchemaBuild

[jira] [Resolved] (KAFKA-8146) WARNING: An illegal reflective access operation has occurred

[ https://issues.apache.org/jira/browse/KAFKA-8146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-8146. -- Resolution: Fixed Warnings mentioned in the description are fixed in Kafka 2.4.0 release. > WARNING: A

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

See

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

See Changes: [wangguoz] KAFKA-9335: Fix StreamPartitionAssignor regression in repartition topics [jason] KAFKA-9065; Fix endless loop when loading group/transaction metadata -