Re: [VOTE] KIP-749: Add --files and --file-separator options to the ConsoleProducer

2021-06-16 Thread wenbing shen
Thanks, Boyang and Luke, As of present: - binding: +1 (Boyang) - non-binding: +1 (Luke) Can anyone else review this KIP? Regards, Wenbing On 2021/06/16 10:36:14, wenbing shen wrote: > Thanks for your comments Boyang. > > I updated the KIP to remove the code details you mentioned

Re: [VOTE] KIP-749: Add --files and --file-separator options to the ConsoleProducer

2021-06-16 Thread wenbing shen
e `proposed > changes` section and no need to go deep, since this is not a major feature > or architectural change. > > Other than that, +1 (binding) from me. > > Boyang > > On Sun, Jun 6, 2021 at 10:54 PM wenbing shen > wrote: > > > Thanks for your comments Ran

Re: [VOTE] KIP-752: Support --bootstrap-server in ReplicaVerificationTool

2021-06-09 Thread wenbing shen
Hi Dongjin, Thanks for the KIP. +1 (non-binding) Thanks. Wenbing Dongjin Lee 于2021年6月10日周四 上午10:04写道: > Thanks, Gwen and Luke, > > As of present: > - binding: +1 (Gwen) > - non-binding: +1 (Luke) > > Anyone else? > > Regards, > Dongjin > > On Thu, Jun 10, 2021 at 1:24 AM Gwen Shapira > wrote:

Re: [VOTE] KIP-749: Add --files and --file-separator options to the ConsoleProducer

2021-06-06 Thread wenbing shen
t; the new options are favored and what's the current workaround? > >> 2. Could you separate out the public interface and proposed changes > >> sections, such that the new options are put in the former section and > the > >> expected changes are in latter. > >>

Re: [VOTE] KIP-749: Add --files and --file-separator options to the ConsoleProducer

2021-06-06 Thread wenbing shen
arate out the public interface and proposed changes > sections, such that the new options are put in the former section and the > expected changes are in latter. > 3. I don't see a necessity to add support for different file separators, > could you elaborate? > > Boyang > > On

[VOTE] KIP-749: Add --files and --file-separator options to the ConsoleProducer

2021-06-05 Thread wenbing shen
Hi all, I'd like to start a vote on KIP-749 to add two options (--files and --files-separator) to ConsoleProducer. https://cwiki.apache.org/confluence/display/KAFKA/KIP-749:+Add+--files+and+--file-separator+options+to+the+ConsoleProducer Thanks, Wenbing

[DISCUSS] KIP-749: Add --files and --file-separator options to the ConsoleProducer

2021-06-04 Thread wenbing shen
Hi all I'd like to discuss the following kip, any suggestions are welcome. https://cwiki.apache.org/confluence/display/KAFKA/KIP-749%3A+Add+--files+and+--file-separator+options+to+the+ConsoleProducer Many thanks, Wenbing

[jira] [Created] (KAFKA-12891) Add --files and --file-separator options to the ConsoleProducer

2021-06-04 Thread Wenbing Shen (Jira)
Wenbing Shen created KAFKA-12891: Summary: Add --files and --file-separator options to the ConsoleProducer Key: KAFKA-12891 URL: https://issues.apache.org/jira/browse/KAFKA-12891 Project: Kafka

[jira] [Resolved] (KAFKA-12734) LazyTimeIndex & LazyOffsetIndex may cause niobufferoverflow when skip activeSegment sanityCheck

2021-04-30 Thread Wenbing Shen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wenbing Shen resolved KAFKA-12734. -- Resolution: Duplicate Duplicate with jiraId KAFKA-10471, This problem has been fixed in

[jira] [Created] (KAFKA-12734) LazyTimeIndex & LazyOffsetIndex may cause niobufferoverflow when skip activeSegment sanityCheck

2021-04-29 Thread Wenbing Shen (Jira)
Wenbing Shen created KAFKA-12734: Summary: LazyTimeIndex & LazyOffsetIndex may cause niobufferoverflow when skip activeSegment sanityCheck Key: KAFKA-12734 URL: https://issues.apache.org/jira/browse/KAFKA-1

[jira] [Resolved] (KAFKA-12680) Failed to restart the broker in kraft mode

2021-04-21 Thread Wenbing Shen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wenbing Shen resolved KAFKA-12680. -- Resolution: Not A Problem > Failed to restart the broker in kraft m

[jira] [Reopened] (KAFKA-12680) Failed to restart the broker in kraft mode

2021-04-21 Thread Wenbing Shen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wenbing Shen reopened KAFKA-12680: -- > Failed to restart the broker in kraft m

[jira] [Resolved] (KAFKA-12680) Failed to restart the broker in kraft mode

2021-04-21 Thread Wenbing Shen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wenbing Shen resolved KAFKA-12680. -- Resolution: Cannot Reproduce > Failed to restart the broker in kraft m

[jira] [Created] (KAFKA-12702) Unhandled exception caught in InterBrokerSendThread

2021-04-21 Thread Wenbing Shen (Jira)
Wenbing Shen created KAFKA-12702: Summary: Unhandled exception caught in InterBrokerSendThread Key: KAFKA-12702 URL: https://issues.apache.org/jira/browse/KAFKA-12702 Project: Kafka Issue

[jira] [Created] (KAFKA-12684) The valid partition list is incorrectly replaced by the successfully elected partition list

2021-04-18 Thread Wenbing Shen (Jira)
Wenbing Shen created KAFKA-12684: Summary: The valid partition list is incorrectly replaced by the successfully elected partition list Key: KAFKA-12684 URL: https://issues.apache.org/jira/browse/KAFKA-12684

[jira] [Created] (KAFKA-12680) Failed to restart the broker in kraft mode

2021-04-17 Thread Wenbing Shen (Jira)
Wenbing Shen created KAFKA-12680: Summary: Failed to restart the broker in kraft mode Key: KAFKA-12680 URL: https://issues.apache.org/jira/browse/KAFKA-12680 Project: Kafka Issue Type: Bug

[jira] [Resolved] (KAFKA-12445) Improve the display of ConsumerPerformance indicators

2021-04-16 Thread Wenbing Shen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wenbing Shen resolved KAFKA-12445. -- Resolution: Won't Do > Improve the display of ConsumerPerformance in

[VOTE] KIP-727 Add --under-preferred-replica-partitions option to describe topics command

2021-04-15 Thread wenbing shen
Hi all, I'd like to start a vote on KIP-727 to add two options (--non-preferred-leader and --non-preferred-leader-json) in TopicCommand to directly get the list of partitions whose leader is in the non-preferred replica and support to output it to json format. https://cwiki.apache.org/confluen

Re: [DISCUSS] KIP-727 Add --under-preferred-replica-partitions option to describe topics command

2021-04-10 Thread wenbing shen
Dear all, If no one has further comments. I want to start a vote thread next week. Thank you, Wenbing wenbing shen 于2021年4月1日周四 上午2:13写道: > Hi Tom, > Thank you so much for your good suggestions. > Based on your suggestions above, I've updated in the KIP-727. > > I used t

Re: [DISCUSS] KIP-727 Add --under-preferred-replica-partitions option to describe topics command

2021-03-31 Thread wenbing shen
re human readable output, but maybe > `--non-preferred-leader-json` (instead of --non-preferred-leader) or > `--non-preferred-leader-format=json` (as well as --non-preferred-leader) is > a more obvious way to do it. > > Kind regards, > > Tom > > On Sat, Mar 27, 2021

[DISCUSS] KIP-727 Add --under-preferred-replica-partitions option to describe topics command

2021-03-27 Thread wenbing shen
Hi everyone, I'd like to discuss the following proposal to add --under-preferred-replica-partitions option to describe topics command. https://cwiki.apache.org/confluence/display/KAFKA/KIP-727%3A+Add+--under-preferred-replica-partitions+option+to+describe+topics+command Many thanks, Wenbing

[jira] [Created] (KAFKA-12556) Add --under-preferred-replica-partitions option to describe topics command

2021-03-25 Thread Wenbing Shen (Jira)
Wenbing Shen created KAFKA-12556: Summary: Add --under-preferred-replica-partitions option to describe topics command Key: KAFKA-12556 URL: https://issues.apache.org/jira/browse/KAFKA-12556 Project

[jira] [Created] (KAFKA-12493) The controller should handle the consistency between the controllerContext and the partition replicas assignment on zookeeper

2021-03-17 Thread Wenbing Shen (Jira)
Wenbing Shen created KAFKA-12493: Summary: The controller should handle the consistency between the controllerContext and the partition replicas assignment on zookeeper Key: KAFKA-12493 URL: https

[jira] [Created] (KAFKA-12454) Add ERROR logging on kafka-log-dirs when given brokerIds do not exist in current kafka cluster

2021-03-11 Thread Wenbing Shen (Jira)
Wenbing Shen created KAFKA-12454: Summary: Add ERROR logging on kafka-log-dirs when given brokerIds do not exist in current kafka cluster Key: KAFKA-12454 URL: https://issues.apache.org/jira/browse/KAFKA-12454

[jira] [Created] (KAFKA-12445) Improve the display of ConsumerPerformance indicators

2021-03-09 Thread Wenbing Shen (Jira)
Wenbing Shen created KAFKA-12445: Summary: Improve the display of ConsumerPerformance indicators Key: KAFKA-12445 URL: https://issues.apache.org/jira/browse/KAFKA-12445 Project: Kafka Issue

Re: [jira] [Created] (KAFKA-12157) test Upgrade 2.7.0 from 2.0.0 occur a question

2021-01-07 Thread wenbing shen
Hi,team I ran into a problem while testing the 2.0.0 rolling upgrade 2.7.0. I tried to reproduce it again and it failed. I am curious how this problem is caused, can anyone help analyze it? Thanks. Wenbing Wenbing Shen (Jira) 于2021年1月7日周四 下午6:26写道: > Wenbing Shen created KAFKA-12

[jira] [Created] (KAFKA-12157) test Upgrade 2.7.0 from 2.0.0 occur a question

2021-01-07 Thread Wenbing Shen (Jira)
Wenbing Shen created KAFKA-12157: Summary: test Upgrade 2.7.0 from 2.0.0 occur a question Key: KAFKA-12157 URL: https://issues.apache.org/jira/browse/KAFKA-12157 Project: Kafka Issue Type

Re: [DISCUSS] KIP-702: The control plane needs to force the validation of requests from the controller

2021-01-06 Thread wenbing shen
Hi, Can we have some discussion about this KIP? thanks, Wenbing On 2021/01/05 12:19:11, wenbing shen wrote: > Hi, > > I'd like to start the discussion on KIP-702 to enforce validation of control > requests for the control plane.The client can define the "bootstrap-serv

[DISCUSS] KIP-702: The control plane needs to force the validation of requests from the controller

2021-01-05 Thread wenbing shen
splay/KAFKA/KIP-702%3A+The+control+plane+needs+to+force+the+validation+of+requests+from+the+controller Regards, Wenbing Shen

[jira] [Created] (KAFKA-10904) There is a misleading log when the replica fetcher thread handles offsets that are out of range

2021-01-05 Thread Wenbing Shen (Jira)
Wenbing Shen created KAFKA-10904: Summary: There is a misleading log when the replica fetcher thread handles offsets that are out of range Key: KAFKA-10904 URL: https://issues.apache.org/jira/browse/KAFKA-10904

[jira] [Created] (KAFKA-10891) The control plane needs to force the validation of requests from the controller

2020-12-29 Thread Wenbing Shen (Jira)
Wenbing Shen created KAFKA-10891: Summary: The control plane needs to force the validation of requests from the controller Key: KAFKA-10891 URL: https://issues.apache.org/jira/browse/KAFKA-10891

[jira] [Created] (KAFKA-10889) The log cleaner is not working for topic partitions

2020-12-25 Thread Wenbing Shen (Jira)
Wenbing Shen created KAFKA-10889: Summary: The log cleaner is not working for topic partitions Key: KAFKA-10889 URL: https://issues.apache.org/jira/browse/KAFKA-10889 Project: Kafka Issue

[jira] [Created] (KAFKA-10886) Kafka crashed in windows environment2

2020-12-23 Thread Wenbing Shen (Jira)
Wenbing Shen created KAFKA-10886: Summary: Kafka crashed in windows environment2 Key: KAFKA-10886 URL: https://issues.apache.org/jira/browse/KAFKA-10886 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-10882) When sending a response to the client,a null pointer exception has occurred in the error code set

2020-12-22 Thread Wenbing Shen (Jira)
Wenbing Shen created KAFKA-10882: Summary: When sending a response to the client,a null pointer exception has occurred in the error code set Key: KAFKA-10882 URL: https://issues.apache.org/jira/browse/KAFKA-10882