Re: Help for contributing

2024-07-28 Thread jiang dou
Hello: You can find out how to contribute here: https://kafka.apache.org/contributing Thank you meisam jafari 于2024年7月28日周日 13:50写道: > Hello there, > > I am very enthusiastic to contributing to the kafka, recently I read the > kafka definitive guide book and got insights how kafka works, then

Re: [DISCUSS] Apache Kafka 3.9.0 release

2024-07-11 Thread jiang dou
hello KIP-1049 ( https://cwiki.apache.org/confluence/display/KAFKA/KIP-1049%3A+Add+config+log.summary.interval.ms+to+Kafka+Streams) is accepted. And a PR has been submitted (https://github.com/apache/kafka/pull/16509) So could you please include KIP-1049 in 3.9.0? Chia-Ping Tsai 于2024年7月12日周五 0

Re: [VOTE] KIP-1049: Add config log.summary.interval.ms to Kafka Streams

2024-07-09 Thread jiang dou
/kafka/pull/16509/files Bruno Cadonna 于2024年6月18日周二 17:10写道: > Hi, > > +1 (binding) > > Since the voting was open for at least 72 hours and you got 4 binding +1 > and no -1, you can close the vote and open a PR. > > Best, > Bruno > > On 6/17/24 7:11 AM, jiang do

Re: [DISCUSS] KIP-1065: Add "retry" return-option to ProductionExceptionHandler

2024-07-02 Thread jiang dou
Thanks for the KIP I think adding ProductionExceptionHandlerResponse.RETRY is very valuable But I agree with Sophie Blee-Goldman: all topics in the same way. The caller can determine whether the topic exists and take appropriate action. The judgment logic of the ProductionExceptionHandler will a

Re: [VOTE] KIP-1049: Add config log.summary.interval.ms to Kafka Streams

2024-06-16 Thread jiang dou
> > > +1 (binding) > > > > On 6/11/24 1:17 PM, Sophie Blee-Goldman wrote: > > > +1 (binding) > > > > > > Thanks for the KIP! > > > > > > On Tue, Jun 11, 2024 at 5:37 AM jiang dou > wrote: > > > > > >> HI

[VOTE] KIP-1049: Add config log.summary.interval.ms to Kafka Streams

2024-06-11 Thread jiang dou
HI I would like to start a vote for KIP-1049: Add config log.summary.interval.ms to Kafka Streams KIP: https://cwiki.apache.org/confluence/display/KAFKA/KIP-1049%3A+Add+config+log.summary.interval.ms+to+Kafka+Streams Discussion thread: https://lists.apache.org/thread/rjqslkt46y5zlg0552rloqjfm5ddzk

Re: [DISCUSS] KIP-1045 Decide MockAdminClient to move to public api or not

2024-06-06 Thread jiang dou
hi Thank you KIP, but I don't agree with putting mock methods or classes into src folder , Unless there is a reason to put the mock class in the src folder (for example: multi-threaded execution cannot be verified under @Test) Placing the mock class under src will increase maintenance costs, and

Re: [DISCUSS] KIP-1049: Add config log.summary.interval.ms to Kafka Streams

2024-06-05 Thread jiang dou
that > > you're proposing to add this to StreamsConfig, which makes sense to me. > But > > please update the KIP to say this somewhere. > > > > Otherwise the KIP LGTM. Anyone else have thoughts on this? > > > > On Thu, May 23, 2024 at 12:19 AM jiang dou wrote:

Re: [DISCUSS] KIP-1049: Add config log.summary.interval.ms to Kafka Streams

2024-06-05 Thread jiang dou
ig > is being added. I assume from the context and Motivation section that > you're proposing to add this to StreamsConfig, which makes sense to me. But > please update the KIP to say this somewhere. > > Otherwise the KIP LGTM. Anyone else have thoughts on this? > > On Thu,

Re: [DISCUSS] KIP-1049: Add config log.summary.interval.ms to Kafka Streams

2024-05-23 Thread jiang dou
read=WARN > > On Wed, May 22, 2024 at 6:46 AM jiang dou wrote: > > > Hi > > > > > > I would like to propose a change in the kafka-stream summary log。 > > > > Now the summary of stream-tread is record every two minutes, and not > > support close or

[DISCUSS] KIP-1049: Add config log.summary.interval.ms to Kafka Streams

2024-05-22 Thread jiang dou
Hi I would like to propose a change in the kafka-stream summary log。 Now the summary of stream-tread is record every two minutes, and not support close or update intervals. When the kafka is running, this is absolutely unnecessary and even harmful since it fills the logs and thus storage spac

Re: Request for Authorization to Create KIP

2024-05-21 Thread jiang dou
You should send your jira ID and wiki ID, Please refer to this address : https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Improvement+Proposals 黃竣陽 于2024年5月21日周二 22:42写道: > I am writing to request authorization to create a KIP. > > Currently, I do not have the necessary permissions to acc

requesting permissions to contribute to Apache Kafka.

2024-05-20 Thread jiang dou
hello: my wiki ID is 'bmilk' and Jira ID is 'bmilk' thank you

why check producer record batch is full used uncompressed size, not use the compressed size

2024-05-12 Thread jiang dou
hello Recently I was studying the kafka producer code, I find if enable compressed,allocate memory buffer from buffer pool and check if recordBatch is full use the records uncompressed size。not after compressed size。 This will cause a batch to be sent when there may still be a lot of free space