Chia-Ping Tsai created KAFKA-10014:
--
Summary: Always try to close all channels in Selector#close
Key: KAFKA-10014
URL: https://issues.apache.org/jira/browse/KAFKA-10014
Project: Kafka
Issue
Chia-Ping Tsai created KAFKA-9918:
-
Summary: SslEngineFactory is NOT closed when channel is closing
Key: KAFKA-9918
URL: https://issues.apache.org/jira/browse/KAFKA-9918
Project: Kafka
Issue
Chia-Ping Tsai created KAFKA-9854:
-
Summary: Re-authenticating causes mismatched parse of response
Key: KAFKA-9854
URL: https://issues.apache.org/jira/browse/KAFKA-9854
Project: Kafka
Issue
Chia-Ping Tsai created KAFKA-9786:
-
Summary: fix flaky
MetricsTest.testGeneralBrokerTopicMetricsAreGreedilyRegistered
Key: KAFKA-9786
URL: https://issues.apache.org/jira/browse/KAFKA-9786
Project
[
https://issues.apache.org/jira/browse/KAFKA-5889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-5889.
---
Resolution: Won't Fix
MetricsTest.testMetricsLeak was removed by
https://github.com/apache
[
https://issues.apache.org/jira/browse/KAFKA-9721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-9721.
---
Resolution: Won't Fix
ReassignPartitionsCommand does not guarantee to "complete" t
>
> Would you please choose another KIP number, maybe 583, I also see KIP-582
> discussion thread appears in the mail list, and insert into table [KIPs under
> discussion].
>
>
> Best Regards,
> Cheng Pan
> -- Original --
> From:
hi
this ticket is about to records partition metrics rather than topic metrics. It
helps us to observe more precis metrics for specify partition. The downside is
that broker needs more space to keep metrics and the origin metrics interface
(tags) is broken since this ticket adds new tag
Chia-Ping Tsai created KAFKA-9730:
-
Summary: add tag "partition" to BrokerTopicMetrics so as to
observe the metrics of partition in the same broker
Key: KAFKA-9730
URL: https://issues.apache.org/jira/br
[
https://issues.apache.org/jira/browse/KAFKA-6941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-6941.
---
Resolution: Won't Fix
> when passing port = 0 to worker, the advertisedPort still i
[
https://issues.apache.org/jira/browse/KAFKA-6931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-6931.
---
Resolution: Won't Fix
> Make worker id configura
[
https://issues.apache.org/jira/browse/KAFKA-7084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-7084.
---
Resolution: Won't Fix
> NewTopicBuilder#config should accept Map rather than
&g
[
https://issues.apache.org/jira/browse/KAFKA-9476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-9476.
---
Resolution: Duplicate
As KAFKA-9712 has PR, this ticket get closed as duplicate.
> Wor
Chia-Ping Tsai created KAFKA-9721:
-
Summary: ReassignPartitionsCommand#reassignPartitions does not
Key: KAFKA-9721
URL: https://issues.apache.org/jira/browse/KAFKA-9721
Project: Kafka
Issue
Chia-Ping Tsai created KAFKA-9711:
-
Summary: The authentication failure caused by
SSLEngine#beginHandshake is not properly caught and handled
Key: KAFKA-9711
URL: https://issues.apache.org/jira/browse/KAFKA-9711
Chia-Ping Tsai created KAFKA-9686:
-
Summary: MockConsumer#endOffsets should be idempotent
Key: KAFKA-9686
URL: https://issues.apache.org/jira/browse/KAFKA-9686
Project: Kafka
Issue Type: Bug
Chia-Ping Tsai created KAFKA-9654:
-
Summary: ReplicaAlterLogDirsThread can't be created again if the
previous ReplicaAlterLogDirsThreadmeet encounters leader epoch error
Key: KAFKA-9654
URL: https
Chia-Ping Tsai created KAFKA-9599:
-
Summary: create unique sensor to record group rebalance
Key: KAFKA-9599
URL: https://issues.apache.org/jira/browse/KAFKA-9599
Project: Kafka
Issue Type
Chia-Ping Tsai created KAFKA-9476:
-
Summary: the error "Scanner SubTypeScanner was not configured"
caused by invalid jar when starting worker
Key: KAFKA-9476
URL: https://issues.apache.org/jira/browse/
Chia-Ping Tsai created KAFKA-8861:
-
Summary: Fix flaky
RegexSourceIntegrationTest.testMultipleConsumersCanReadFromPartitionedTopic
Key: KAFKA-8861
URL: https://issues.apache.org/jira/browse/KAFKA-8861
hi folks,
I love GNU/Linux but it pains me to see broken build on windows. Could someone
take a look at PR: https://github.com/apache/kafka/pull/6208 ? It enables kafka
to embrace windows again.
Cheers,
Chia-Ping
We have following votes:
non-binding
1. John Roesler
2. vito jeng
3. Richard Yu
4. Bill Bejeck
5. Satish Duggana
binding
1. Matthias J. Sax
2. Ismael Juma
3. Damian Guy
KIP-331 has passed. Thanks for all votes
--
Chia-Ping
On 2018/07/05 14:45:01, Chia-Ping Tsai wrote:
> hi all,
>
>
(just bump)
We have following votes:
non-binding
1. John Roesler
2. vito jeng
3. Richard Yu
4. Bill Bejeck
5. Satish Duggana
binding
1. Matthias J. Sax
2. Ismael Juma
it needs one more ticket :)
Cheers,
Chia-Ping
On 2018/07/05 14:45:01, Chia-Ping Tsai wrote:
> hi all,
>
> I w
hi folks,
The props passed to Connector#start is not a clone so any change to props will
impact the props itself. If we try to pause and then resume a connector, the
props passed to connector is what we changed before. However, the "changes"
don't sync to config store. So if connector restart
eption` and thus, it seems to be a backward incompatible change.
> Hence, I am not sure if we can actually move forward easily with this KIP.
>
> Nit: `RecordCollectorImpl` is an internal class that implements
> `RecordCollector` -- should `RecordCollector extends AutoCloseable`
ered the cases
> > where Autoclosable is so desired several times! Let me inspect more
> > candidate classes as well.
> >
> > +1. I also refined your KIP a little bit.
> >
> > Best,
> > Dongjin
> >
> > On Thu, Sep 27, 2018 at 12:21 PM Chia-Ping
hi Yishun
Thanks for nice KIP!
Q1)
Why VerifiableProducer extend Closeable rather than AutoCloseable?
Q2)
I grep project and then noticed there are other close methods but do not
implement AutoCloseable.
For example:
1) WorkerConnector
2) MemoryRecordsBuilder
3) MetricsReporter
4)
gt; myData.toByteArrayOrWhatever()", right? (and of course similar for
> deserializers).
>
> This sounds right to me, so if that is right, I'm still a non-binding +1.
>
> Thanks,
> -John
>
> On Thu, Sep 20, 2018 at 10:12 PM Chia-Ping Tsai wrote:
>
> > KI
I think that may not be desirable due to the method that
> passes headers. So, it doesn't make sense to discuss two separate changes
> to the same interfaces in isolation, we should figure out how we want them
> to work holistically.
>
> Ismael
>
> On Fri, Jul 20, 2018 at 3:50 AM Ch
Thanks for all votes. KIP-367 has passed!!!
binding votes (3) :
Matthias J. Sax
Harsha
Jason Gustafson
non-binding votes (6):
Dongjin Lee
Manikumar
Mickael Maison
vito jeng
Colin McCabe
Bill Bejeck
Cheers,
Chia-Ping
On 2018/09/08 18:27:59, Chia-Ping Tsai wrote:
> Hi All,
>
> I'd li
, TimeUnit) call to avoid breaking compatibility, however.
> Does the KIP specify keeping the old overload? I can't seem to access the
> wiki now.
>
> best,
> Colin
>
>
> On Sat, Sep 8, 2018, at 11:27, Chia-Ping Tsai wrote:
> > Hi All,
> >
> > I'd like to
; - `AdminClient#close(long duration, TimeUnit unit)` is `abstract` and
> the KIP should contain this.
>
>
>
> -Matthias
>
>
>
> On 9/8/18 11:22 AM, Chia-Ping Tsai wrote:
> >> It's a little hard to read -- it's easier if you just list the methods
> >
Hi All,
I'd like to put KIP-367 to the vote.
https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=89070496
--
Chia-Ping
ndicate if the get deprecated or added. Please
> don't show a diff as in a patch :)
>
> Is there already a JIRA for this? If not, please create on and link it
> in the KIP.
>
> Besides this, I think you can start a VOTE.
>
>
>
> -Matthias
>
> On 9/3/18 11:2
Chia-Ping Tsai created KAFKA-7391:
-
Summary: Introduce close(Duration) to Producer and AdminClient
instead of close(long, TimeUnit)
Key: KAFKA-7391
URL: https://issues.apache.org/jira/browse/KAFKA-7391
a similar change to
> AdminClient?
>
> -Jason
>
> On Tue, Aug 28, 2018 at 2:32 AM, Chia-Ping Tsai wrote:
>
> > (re-start the thread for KIP-367 because I enter the incorrect topic in
> > first post)
> >
> > hi all
> >
> > I would like to
AdminClient?
>
> -Jason
>
> On Tue, Aug 28, 2018 at 2:32 AM, Chia-Ping Tsai wrote:
>
> > (re-start the thread for KIP-367 because I enter the incorrect topic in
> > first post)
> >
> > hi all
> >
> > I would like to start a discussion of KIP-36
(re-start the thread for KIP-367 because I enter the incorrect topic in first
post)
hi all
I would like to start a discussion of KIP-367 [1]. It is similar to KIP-358 and
KIP-266 which is trying to substitute Duration for (long, TimeUnit).
[1]
fix the topic of this discussion :(
On 2018/08/28 08:59:36, Chia-Ping Tsai wrote:
> hi all
>
> I would like to start a discussion of KIP-367 [1]. It is similar to KIP-358
> and KIP-266 which is trying to substitute Duration for (long, TimeUnit).
>
> [1] https://cwiki.apa
hi all
I would like to start a discussion of KIP-367 [1]. It is similar to KIP-358 and
KIP-266 which is trying to substitute Duration for (long, TimeUnit).
[1] https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=89070496
--
Chia-Ping
hi kafka,
I'm starting a vote on KIP-348
https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=89065853
--
chia-ping
t in there, it likely is not public API.
>
> In the case of Connect, the only public Java APIs are in their own module,
> connect-api. Everything in the other connect modules are considered
> internal implementation details.
>
> -Ewen
>
>
> On Fri, Jul 27, 2018 at 7:15 PM C
Chia-Ping Tsai created KAFKA-7253:
-
Summary: The connector type responded by worker is always null
when creating connector
Key: KAFKA-7253
URL: https://issues.apache.org/jira/browse/KAFKA-7253
t; since it will still be possible to return null here,
> right?
>
> best,
> Colin
>
>
> On Tue, Jul 31, 2018, at 01:10, Chia-Ping Tsai wrote:
> > hi all,
> >
> > Please take a look at the KIP-348[1] if you have free cycel. It bring a
> > little change
Bumping up!
On 2018/07/09 08:50:07, Viktor Somogyi wrote:
> Hi folks,
>
> I've published KIP-336 which is about consolidating the
> Serializer/Deserializer interfaces.
>
> Basically the story here is when ExtendedSerializer and
> ExtendedDeserializer were added we still supported Java 7 and
hi all,
Please take a look at the KIP-348[1] if you have free cycel. It bring a little
change to the usage of SourceTask#poll()
[1]
https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=89065853=true#KIP-348EliminatenullfromSourceTask#poll()-Status
Cheers,
Chia-Ping
hi Kafka
There is a section[1] listing the packages which have public interfaces.
However, it doesn't include any connect-related packages. It would be better to
have a list used to highlight the public interfaces for connector. Otherwise,
connector user may misuse the internal interface in
you all.
--
Chia-Ping
On 2018/07/25 18:38:26, Kamal Chandraprakash
wrote:
> Chia-Ping Tsai,
>
> The voting has passed. Dong Lin (binding) is a committer.
>
> On Wed, Jul 25, 2018 at 8:24 AM Chia-Ping Tsai wrote:
>
> > Current voting result is shown below.
> &
Current voting result is shown below.
+2 (binding)
1) Jason Gustafson
2) Gwen Shapira
+4 (non-binding)
1) Colin McCabe
2) Manikumar
3) Dong Lin
4) Vahid S Hashemian
Need one more binding vote please
Cheers,
Chia-Ping
On 2018/07/16 08:10:51, Chia-Ping Tsai wrote:
> hi fo
> The approach where all the methods have a default implementation and the
> user chooses to override one of them seems the most appealing to me given
> the current state.
sounds good. one Q: Which implementation is suitable for
serialize()/deserialize()? maybe just throw exception?
BTW,
work holistically.
>
> Ismael
>
> On Fri, Jul 20, 2018 at 3:50 AM Chia-Ping Tsai wrote:
>
> > > The KIP needs 3 binding votes to pass.
> >
> > Thanks for the reminder. I will reopen the ballot box until we get 3
> > tickets.
> >
> > > I still
3 binding votes to pass. I still think we should include the
> details of how things will look like with the headers being passed to
> serializers/deserializers to ensure things actually make sense as a whole.
>
> Ismael
>
>
> On Sun, 8 Jul 2018, 18:31 Chia-Ping Tsai, wrote:
Mon, Jul 16, 2018 at 2:23 PM, Dong Lin wrote:
>
> > +1
> >
> > Thanks!
> > Dong
> >
> > On Mon, Jul 16, 2018 at 9:17 AM, Vahid S Hashemian <
> > vahidhashem...@us.ibm.com> wrote:
> >
> > > +1 (non-binding)
> > >
> > &g
here is my two cents.
In order to keep the BC, SC, and correct deprecation cycle(deprecate
Serializer/Deserializer in 2.0), the solution of this issue is to introduce a
new class to replace the Serializer and Deserializer. The new class should be a
subclass of Serializer/Deserializer and it
hi folks,
The discussion[1] of KIP-338[2] did not get any objection for last 6 days so it
is time to start the voting thread.
Thanks for your time!
[1]
https://lists.apache.org/thread.html/9bd4e61b73c901b51132ada49743b9b703d40b85fc4eeaa5c9099900@%3Cdev.kafka.apache.org%3E
[2]
hi Kafka,
KIP-338 is trying to make us exclude internal topics easily when using the
kafka-topics.sh. An new option will be added to kafka-topics.sh (TopicCommand)
and user can use the option to exclude all internal topics when running the
list or describe command.
Chia-Ping Tsai created KAFKA-7139:
-
Summary: Support to exclude the internal topics in kafka-topics.sh
command
Key: KAFKA-7139
URL: https://issues.apache.org/jira/browse/KAFKA-7139
Project: Kafka
All,
The 72 hours has passed. The vote result of KIP-313 is shown below.
1 binding vote (Matthias J. Sax)
4 non-binding votes (John Roesler, Richard Yu, vito jeng and Chia-Ping)
Cheers,
Chia-Ping
On 2018/07/05 14:45:01, Chia-Ping Tsai wrote:
> hi all,
>
> I would like to sta
ael
>
> On Thu, 5 Jul 2018, 07:45 Chia-Ping Tsai, wrote:
>
> > hi all,
> >
> > I would like to start voting on "KIP-331 Add default implementation to
> > close() and configure() for Serializer, Deserializer and Serde"
> >
> >
> > https
hi all,
I would like to start voting on "KIP-331 Add default implementation to close()
and configure() for Serializer, Deserializer and Serde"
fka jar containing your change on my classpath at
> run time, will it still work?
>
> I think it should be binary compatible, assuming Oracle didn't do anything
> crazy, since all the method references would be the same. It might we worth
> an experiment, though.
>
> Thanks,
&g
ohn Roesler wrote:
> Hi Chia-Ping,
>
> I couldn't find KIP-331 in the list of KIPs (
> https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Improvement+Proposals
> ).
>
> Can you provide a link, please?
>
> Thanks,
> -John
>
> On Sun, Jul 1, 2018 at 11
hi folks,
KIP-331 is waiting for any suggestions, feedback and reviews. The main purpose
of the KIP-331 is to add empty implementations to the close() and configure()
so as to user can write less code to develop custom Serialzier, Deserializer
and Serde.
Cheers,
Chia-Ping
Chia-Ping Tsai created KAFKA-7084:
-
Summary: NewTopicBuilder#config should accept Map
rather than Map
Key: KAFKA-7084
URL: https://issues.apache.org/jira/browse/KAFKA-7084
Project: Kafka
thanks for the helps!
On 2018/06/12 17:36:05, "Matthias J. Sax" wrote:
> Done.
>
> On 6/12/18 12:37 AM, Chia-Ping Tsai wrote:
> > dear Kafka,
> >
> > Please give me the permission to create KIP. the email is
> > "chia7...@gmail.com"
Chia-Ping Tsai created KAFKA-7048:
-
Summary: NPE when creating >1 connectors
Key: KAFKA-7048
URL: https://issues.apache.org/jira/browse/KAFKA-7048
Project: Kafka
Issue Type: Improvem
dear Kafka,
Please give me the permission to create KIP. the email is "chia7...@gmail.com"
and the account is "chia7712"
Best Regards,
chia-ping
Chia-Ping Tsai created KAFKA-7036:
-
Summary: Complete the docs of KafkaConsumer#poll
Key: KAFKA-7036
URL: https://issues.apache.org/jira/browse/KAFKA-7036
Project: Kafka
Issue Type
Chia-Ping Tsai created KAFKA-7032:
-
Summary: The TimeUnit is neglected by KakfaConsumer#close(long,
TimeUnit)
Key: KAFKA-7032
URL: https://issues.apache.org/jira/browse/KAFKA-7032
Project: Kafka
Chia-Ping Tsai created KAFKA-7014:
-
Summary: Guarantee the byte buffer returned by Serializer is
reusable
Key: KAFKA-7014
URL: https://issues.apache.org/jira/browse/KAFKA-7014
Project: Kafka
Chia-Ping Tsai created KAFKA-6992:
-
Summary: Configuring the batch.size to zero won't disable the
batching entirely
Key: KAFKA-6992
URL: https://issues.apache.org/jira/browse/KAFKA-6992
Project
Chia-Ping Tsai created KAFKA-6941:
-
Summary: when passing port = 0 to worker, the advertisedPort still
is 0 rather than a random port
Key: KAFKA-6941
URL: https://issues.apache.org/jira/browse/KAFKA-6941
Chia-Ping Tsai created KAFKA-6931:
-
Summary: Make worker id configurable
Key: KAFKA-6931
URL: https://issues.apache.org/jira/browse/KAFKA-6931
Project: Kafka
Issue Type: Task
[
https://issues.apache.org/jira/browse/KAFKA-6870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-6870.
---
Resolution: Fixed
Reviewer: Rajini Sivaram
Thanks for the reviews. [~rsivaram
hi Kafka,
I'm reading the connector flow. And I noticed the methods
"initialize(ConnectorContext, List
Chia-Ping Tsai created KAFKA-6870:
-
Summary: Concurrency conflicts in SampledStat
Key: KAFKA-6870
URL: https://issues.apache.org/jira/browse/KAFKA-6870
Project: Kafka
Issue Type: Bug
501 - 576 of 576 matches
Mail list logo