Apply for JIRA contributor authority

Hi, I want to contribute to Apache Kafka. Would you please give me the contributor permission? My JIRA ID is xinzhuxianshenger. | | xinzhuxiansheng | | xinzhuxiansh...@126.com | 签名由网易邮箱大师定制

[jira] [Created] (KAFKA-9351) Higher count in destination cluster using Kafka MM2

Nitish Goyal created KAFKA-9351: --- Summary: Higher count in destination cluster using Kafka MM2 Key: KAFKA-9351 URL: https://issues.apache.org/jira/browse/KAFKA-9351 Project: Kafka Issue Type:

[jira] [Reopened] (KAFKA-7994) Improve Stream-Time for rebalances and restarts

[ https://issues.apache.org/jira/browse/KAFKA-7994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reopened KAFKA-7994: Assignee: (was: Richard Yu) I'm not sure we should close this yet, it seems

[jira] [Created] (KAFKA-9350) IllegalStateException when materializing transactional offset commits

Jason Gustafson created KAFKA-9350: -- Summary: IllegalStateException when materializing transactional offset commits Key: KAFKA-9350 URL: https://issues.apache.org/jira/browse/KAFKA-9350 Project:

[jira] [Created] (KAFKA-9349) Investigate new member timeout for dynamic v4 JoinGroup

Sophie Blee-Goldman created KAFKA-9349: -- Summary: Investigate new member timeout for dynamic v4 JoinGroup Key: KAFKA-9349 URL: https://issues.apache.org/jira/browse/KAFKA-9349 Project: Kafka

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

See Changes: [jason] MINOR: upgrade system test should check for ISR rejoin on each roll -- [...truncated 2.78 MB...] org.apache.kafka.streams.TopologyTestDriverTest >

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

See Changes: [jason] MINOR: upgrade system test should check for ISR rejoin on each roll -- [...truncated 2.79 MB...] org.apache.kafka.streams.TopologyTestDriverTest >

[jira] [Created] (KAFKA-9348) Broker shutdown during controller initialization can lead to zombie broker

Jason Gustafson created KAFKA-9348: -- Summary: Broker shutdown during controller initialization can lead to zombie broker Key: KAFKA-9348 URL: https://issues.apache.org/jira/browse/KAFKA-9348

[jira] [Resolved] (KAFKA-661) Prevent a shutting down broker from re-entering the ISR

[ https://issues.apache.org/jira/browse/KAFKA-661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-661. --- Resolution: Fixed This patch is fixed by KIP-320, which adds leader epoch validation to the

[jira] [Resolved] (KAFKA-3410) Unclean leader election and "Halting because log truncation is not allowed"

[ https://issues.apache.org/jira/browse/KAFKA-3410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-3410. Resolution: Resolved I am going to go ahead and close this since it has become a bit dated

[jira] [Created] (KAFKA-9347) Detect deleted log directory before becoming leader

Jason Gustafson created KAFKA-9347: -- Summary: Detect deleted log directory before becoming leader Key: KAFKA-9347 URL: https://issues.apache.org/jira/browse/KAFKA-9347 Project: Kafka Issue

[jira] [Resolved] (KAFKA-3944) After the broker restart, fetchers stopped due to a delayed controlled shutdown message

[ https://issues.apache.org/jira/browse/KAFKA-3944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-3944. Resolution: Fixed > After the broker restart, fetchers stopped due to a delayed controlled

[jira] [Resolved] (KAFKA-1342) Slow controlled shutdowns can result in stale shutdown requests

[ https://issues.apache.org/jira/browse/KAFKA-1342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-1342. Resolution: Fixed > Slow controlled shutdowns can result in stale shutdown requests >

Issue on Spring boot Kafka listener

Hi, Kafka is installed in CentOs machine. Kafka version is 2.4.0. I have written sample java code which consumes data from topic. I am using @KafkaListener(topics = "Device") public void receive(final String record) { System.out.println(record); } This annotation is mapped with one

[jira] [Created] (KAFKA-9346) Consumer fetch offset back-off with pending transactions

Boyang Chen created KAFKA-9346: -- Summary: Consumer fetch offset back-off with pending transactions Key: KAFKA-9346 URL: https://issues.apache.org/jira/browse/KAFKA-9346 Project: Kafka Issue

Re: Permission to create KIP

Done. On 12/30/19 8:00 AM, Sagar wrote: > Hi, > > Its sagarmeansocean > > On Sat, Dec 28, 2019 at 12:29 AM Matthias J. Sax > wrote: > >> What is your wiki account id? >> >> >> -Matthias >> >> On 12/27/19 7:12 AM, Sagar wrote: >>> Hi, >>> >>> I have done some work on adding prefix scan for

[jira] [Resolved] (KAFKA-9331) Add option to terminate application when StreamThread(s) die

[ https://issues.apache.org/jira/browse/KAFKA-9331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9331. Resolution: Duplicate > Add option to terminate application when StreamThread(s) die >

Re: Permission to create KIP

Hi, Its sagarmeansocean On Sat, Dec 28, 2019 at 12:29 AM Matthias J. Sax wrote: > What is your wiki account id? > > > -Matthias > > On 12/27/19 7:12 AM, Sagar wrote: > > Hi, > > > > I have done some work on adding prefix scan for state store and would > like > > to create a KIP for the same. >

Re: [DISCUSS] KIP-552: Add interface to handle unused config

Hi, Indeed changing the log level for the whole AbstractConfig is not an option, because logAll is extremely useful. Grouping warnings into 1 (with the count of unused only) will not be a good option for us either. It will still be pretty noisy. Imagine we have 32 partitions and scaled up the

Re: [DISCUSS] KIP-552: Add interface to handle unused config

Hi all, Would printing all the unused configurations in one line, versus N lines, be more helpful? I know that it would greatly reduce the verbosity in log visualization tools like Kibana while still allowing us to see all the relevant information without the need for an explicit action (e.g

[jira] [Created] (KAFKA-9345) Deploy Mirror Maker 2.0 and dynamically modify the topic whitelist through REST API

yzhou created KAFKA-9345: Summary: Deploy Mirror Maker 2.0 and dynamically modify the topic whitelist through REST API Key: KAFKA-9345 URL: https://issues.apache.org/jira/browse/KAFKA-9345 Project: Kafka