[
https://issues.apache.org/jira/browse/KAFKA-3729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated KAFKA-3729:
--
Attachment: 3729.v6.txt
> Auto-configure non-default SerDes passed alongside the topology builder
> --
[
https://issues.apache.org/jira/browse/KAFKA-3729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16794549#comment-16794549
]
Ted Yu commented on KAFKA-3729:
---
3729.v6.txt shows the progress toward passing StreamsConfi
[
https://issues.apache.org/jira/browse/KAFKA-3729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated KAFKA-3729:
--
Attachment: 3729.v6.txt
> Auto-configure non-default SerDes passed alongside the topology builder
> --
[
https://issues.apache.org/jira/browse/KAFKA-3729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16794549#comment-16794549
]
Ted Yu edited comment on KAFKA-3729 at 3/17/19 6:39 PM:
3729.v6.t
[
https://issues.apache.org/jira/browse/KAFKA-3729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated KAFKA-3729:
--
Attachment: (was: 3729.v6.txt)
> Auto-configure non-default SerDes passed alongside the topology builder
>
[
https://issues.apache.org/jira/browse/KAFKA-3729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16794549#comment-16794549
]
Ted Yu edited comment on KAFKA-3729 at 3/18/19 3:06 AM:
3729.v6.t
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16811551#comment-16811551
]
Ted Yu commented on KAFKA-5998:
---
Cleanup delay is controlled by:
{code}
public static f
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16811551#comment-16811551
]
Ted Yu edited comment on KAFKA-5998 at 4/6/19 10:55 AM:
Cleanup d
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16811603#comment-16811603
]
Ted Yu commented on KAFKA-5998:
---
It seems StreamTask can keep track of active tasks. After
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16811681#comment-16811681
]
Ted Yu commented on KAFKA-5998:
---
I made the following change:
{code}
diff --git
a/streams/
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16822446#comment-16822446
]
Ted Yu commented on KAFKA-5998:
---
I wonder if we can use a file, which records reference cou
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16822564#comment-16822564
]
Ted Yu commented on KAFKA-5998:
---
One doubt I had after reading recent comments is that, if
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16827089#comment-16827089
]
Ted Yu commented on KAFKA-5998:
---
[~mparthas]:
>From your comment on Apr 8th, it seems that
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16827123#comment-16827123
]
Ted Yu commented on KAFKA-5998:
---
https://pastebin.com/Y247UZgb shows what I mentioned earli
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16827123#comment-16827123
]
Ted Yu edited comment on KAFKA-5998 at 4/26/19 5:12 PM:
https://p
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16827123#comment-16827123
]
Ted Yu edited comment on KAFKA-5998 at 4/26/19 5:31 PM:
https://p
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846843#comment-16846843
]
Ted Yu commented on KAFKA-5998:
---
Can you move state directory outside of /tmp which is subj
[
https://issues.apache.org/jira/browse/KAFKA-8532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17018152#comment-17018152
]
Ted Yu commented on KAFKA-8532:
---
How about making the following change ?
{code}
diff --git
[
https://issues.apache.org/jira/browse/KAFKA-8532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17018152#comment-17018152
]
Ted Yu edited comment on KAFKA-8532 at 1/17/20 4:13 PM:
How about
[
https://issues.apache.org/jira/browse/KAFKA-8532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17018175#comment-17018175
]
Ted Yu commented on KAFKA-8532:
---
Created https://github.com/apache/kafka/pull/7978
> contr
[
https://issues.apache.org/jira/browse/KAFKA-8532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17018352#comment-17018352
]
Ted Yu commented on KAFKA-8532:
---
Looking at KafkaController.scala in trunk, I don't see
Ex
[
https://issues.apache.org/jira/browse/KAFKA-8532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17018368#comment-17018368
]
Ted Yu commented on KAFKA-8532:
---
Looking at js2.log , I am not sure deadlock was observed.
[
https://issues.apache.org/jira/browse/KAFKA-8532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17018368#comment-17018368
]
Ted Yu edited comment on KAFKA-8532 at 1/17/20 10:42 PM:
-
Looking
[
https://issues.apache.org/jira/browse/KAFKA-8532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17018368#comment-17018368
]
Ted Yu edited comment on KAFKA-8532 at 1/18/20 2:21 AM:
Looking a
[
https://issues.apache.org/jira/browse/KAFKA-8532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17018368#comment-17018368
]
Ted Yu edited comment on KAFKA-8532 at 1/18/20 2:22 AM:
Looking a
[
https://issues.apache.org/jira/browse/KAFKA-8532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17018368#comment-17018368
]
Ted Yu edited comment on KAFKA-8532 at 1/18/20 2:26 AM:
Looking a
[
https://issues.apache.org/jira/browse/KAFKA-9450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17018602#comment-17018602
]
Ted Yu commented on KAFKA-9450:
---
w.r.t. separate column family, since the data in this fami
[
https://issues.apache.org/jira/browse/KAFKA-9455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17019191#comment-17019191
]
Ted Yu commented on KAFKA-9455:
---
Maybe we can also look at (profile) Maps from fastutil suc
[
https://issues.apache.org/jira/browse/KAFKA-9461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17020262#comment-17020262
]
Ted Yu commented on KAFKA-9461:
---
Since we may not see the complete record given any thresho
Ted Yu created KAFKA-9462:
-
Summary: Correct exception message in DistributedHerder
Key: KAFKA-9462
URL: https://issues.apache.org/jira/browse/KAFKA-9462
Project: Kafka
Issue Type: Bug
Re
Ted Yu created KAFKA-9463:
-
Summary: Transient failure in KafkaAdminClientTest.testListOffsets
Key: KAFKA-9463
URL: https://issues.apache.org/jira/browse/KAFKA-9463
Project: Kafka
Issue Type: Test
Ted Yu created KAFKA-9464:
-
Summary: Close the producer in completeShutdown
Key: KAFKA-9464
URL: https://issues.apache.org/jira/browse/KAFKA-9464
Project: Kafka
Issue Type: Bug
Reporter:
Ted Yu created KAFKA-9465:
-
Summary: Enclose consumer call with catching InvalidOffsetException
Key: KAFKA-9465
URL: https://issues.apache.org/jira/browse/KAFKA-9465
Project: Kafka
Issue Type: Improv
[
https://issues.apache.org/jira/browse/KAFKA-9464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu resolved KAFKA-9464.
---
Resolution: Not A Problem
> Close the producer in completeShutdown
> --
>
[
https://issues.apache.org/jira/browse/KAFKA-9471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated KAFKA-9471:
--
Description:
In StreamThreadStateStoreProvider we have:
{code}
if (streamThread.state() == StreamThread.State.D
[
https://issues.apache.org/jira/browse/KAFKA-9471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17022373#comment-17022373
]
Ted Yu commented on KAFKA-9471:
---
[~mjsax][~guozhang]
Please comment.
> Return empty collec
Ted Yu created KAFKA-9471:
-
Summary: Return empty collection for PENDING_SHUTDOWN
Key: KAFKA-9471
URL: https://issues.apache.org/jira/browse/KAFKA-9471
Project: Kafka
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/KAFKA-9471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17022589#comment-17022589
]
Ted Yu commented on KAFKA-9471:
---
I will send out a PR soon alone the above line of thinking
[
https://issues.apache.org/jira/browse/KAFKA-9471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated KAFKA-9471:
--
Description:
In StreamThreadStateStoreProvider we have:
{code}
if (streamThread.state() == StreamThread.State.D
[
https://issues.apache.org/jira/browse/KAFKA-9471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated KAFKA-9471:
--
Summary: Throw exception for DEAD StreamThread.State (was: Return empty
collection for PENDING_SHUTDOWN)
> Th
[
https://issues.apache.org/jira/browse/KAFKA-9471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated KAFKA-9471:
--
Comment: was deleted
(was: I will send out a PR soon alone the above line of thinking.)
> Throw exception for
[
https://issues.apache.org/jira/browse/KAFKA-9471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17022595#comment-17022595
]
Ted Yu commented on KAFKA-9471:
---
[~vitojeng]
Looks like the following query depends on the
[
https://issues.apache.org/jira/browse/KAFKA-9471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17022970#comment-17022970
]
Ted Yu commented on KAFKA-9471:
---
[~vitojeng]
Please let me know if I should proceed with th
[
https://issues.apache.org/jira/browse/KAFKA-9471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu resolved KAFKA-9471.
---
Resolution: Duplicate
> Throw exception for DEAD StreamThread.State
> ---
[
https://issues.apache.org/jira/browse/KAFKA-9504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17032739#comment-17032739
]
Ted Yu commented on KAFKA-9504:
---
It seems the closing of metrics is not enough in terms of
[
https://issues.apache.org/jira/browse/KAFKA-5973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16182694#comment-16182694
]
Ted Yu commented on KAFKA-5973:
---
[~damianguy] [~guozhang]:
Can you take a look ?
Thanks
>
[
https://issues.apache.org/jira/browse/KAFKA-5973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16182775#comment-16182775
]
Ted Yu commented on KAFKA-5973:
---
[~ijuma]:
Among the threads identified by Tom, can you see
[
https://issues.apache.org/jira/browse/KAFKA-5967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16184616#comment-16184616
]
Ted Yu commented on KAFKA-5967:
---
Please go ahead.
> Ineffective check of negative value in
[
https://issues.apache.org/jira/browse/KAFKA-5967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16184644#comment-16184644
]
Ted Yu commented on KAFKA-5967:
---
Once you send out pull request, a committer would assign to
Ted Yu created KAFKA-5988:
-
Summary: Consider removing StreamThread#STREAM_THREAD_ID_SEQUENCE
Key: KAFKA-5988
URL: https://issues.apache.org/jira/browse/KAFKA-5988
Project: Kafka
Issue Type: Improvem
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated KAFKA-5998:
--
Attachment: 5998.v1.txt
{code}
Files.move(source, target, StandardCopyOption.REPLACE_EXISTING);
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16187353#comment-16187353
]
Ted Yu commented on KAFKA-5998:
---
Patch v1 has been attached.
If the .tmp file cannot be ren
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16187353#comment-16187353
]
Ted Yu edited comment on KAFKA-5998 at 10/1/17 3:10 PM:
Patch v1 h
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated KAFKA-5998:
--
Attachment: 5998.v2.txt
Patch v2 enables the log when renaming to secondary fails.
> /.checkpoint.tmp Not found
[
https://issues.apache.org/jira/browse/KAFKA-5988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16187645#comment-16187645
]
Ted Yu commented on KAFKA-5988:
---
Please go ahead.
> Consider removing StreamThread#STREAM_T
[
https://issues.apache.org/jira/browse/KAFKA-5889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16188721#comment-16188721
]
Ted Yu commented on KAFKA-5889:
---
https://builds.apache.org/job/kafka-trunk-jdk7/2836/display
[
https://issues.apache.org/jira/browse/KAFKA-6000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16189947#comment-16189947
]
Ted Yu commented on KAFKA-6000:
---
I wonder if the following had something to do with the prob
[
https://issues.apache.org/jira/browse/KAFKA-5846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16191405#comment-16191405
]
Ted Yu commented on KAFKA-5846:
---
lgtm
> Use singleton NoOpConsumerRebalanceListener in subs
[
https://issues.apache.org/jira/browse/KAFKA-5842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu resolved KAFKA-5842.
---
Resolution: Cannot Reproduce
> QueryableStateIntegrationTest may fail with JDK 7
> ---
[
https://issues.apache.org/jira/browse/KAFKA-5916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated KAFKA-5916:
--
Summary: Upgrade rocksdb dependency to 5.8 (was: Upgrade rocksdb
dependency to 5.7.3)
> Upgrade rocksdb depend
[
https://issues.apache.org/jira/browse/KAFKA-5916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated KAFKA-5916:
--
Description:
Currently we use 5.3.6.
The latest release is 5.8 :
https://github.com/facebook/rocksdb/releases
[
https://issues.apache.org/jira/browse/KAFKA-5973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16193918#comment-16193918
]
Ted Yu commented on KAFKA-5973:
---
bq. which to kill itself, which to kill the whole process
[
https://issues.apache.org/jira/browse/KAFKA-5973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16193918#comment-16193918
]
Ted Yu edited comment on KAFKA-5973 at 10/5/17 11:38 PM:
-
bq. whic
[
https://issues.apache.org/jira/browse/KAFKA-5916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu resolved KAFKA-5916.
---
Resolution: Duplicate
With KAFKA-5576
> Upgrade rocksdb dependency to 5.8
> -
[
https://issues.apache.org/jira/browse/KAFKA-6020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16195223#comment-16195223
]
Ted Yu commented on KAFKA-6020:
---
This needs a KIP, right ?
> Broker side filtering
> --
Ted Yu created KAFKA-6023:
-
Summary: ThreadCache#sizeBytes() should check overflow
Key: KAFKA-6023
URL: https://issues.apache.org/jira/browse/KAFKA-6023
Project: Kafka
Issue Type: Bug
Rep
Ted Yu created KAFKA-6024:
-
Summary: Consider moving validation in KafkaConsumer ahead of call
to acquireAndEnsureOpen()
Key: KAFKA-6024
URL: https://issues.apache.org/jira/browse/KAFKA-6024
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-6024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16196244#comment-16196244
]
Ted Yu commented on KAFKA-6024:
---
Go ahead.
> Consider moving validation in KafkaConsumer ah
[
https://issues.apache.org/jira/browse/KAFKA-5946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated KAFKA-5946:
--
Labels: connector (was: )
> Give connector method parameter better name
> -
[
https://issues.apache.org/jira/browse/KAFKA-6027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16197283#comment-16197283
]
Ted Yu commented on KAFKA-6027:
---
In any of the link where LogDirFailureTest failed, there wo
[
https://issues.apache.org/jira/browse/KAFKA-5943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated KAFKA-5943:
--
Labels: connector (was: )
> Reduce dependency on mock in connector tests
>
[
https://issues.apache.org/jira/browse/KAFKA-5911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated KAFKA-5911:
--
Labels: client (was: )
> Avoid creation of extra Map for futures in KafkaAdminClient
>
[
https://issues.apache.org/jira/browse/KAFKA-6046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16198932#comment-16198932
]
Ted Yu commented on KAFKA-6046:
---
Looking at core/src/main/scala/kafka/server/DelayedDeleteRe
[
https://issues.apache.org/jira/browse/KAFKA-6043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16198944#comment-16198944
]
Ted Yu commented on KAFKA-6043:
---
0.8.1.1 was very old.
Are you able to try newer release ?
[
https://issues.apache.org/jira/browse/KAFKA-6043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16199291#comment-16199291
]
Ted Yu commented on KAFKA-6043:
---
bq. locked <0x00076a922c40> (a java.lang.Object)
This
[
https://issues.apache.org/jira/browse/KAFKA-6043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16199292#comment-16199292
]
Ted Yu commented on KAFKA-6043:
---
Did you see who is holding 0x00076b2e1508 ?
> Kafka 8.
[
https://issues.apache.org/jira/browse/KAFKA-6043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated KAFKA-6043:
--
Attachment: 6043.v1
> Kafka 8.1.1 -
> .ZookeeperConsumerConnector.shutdown(ZookeeperConsumerConnector.scala:110
[
https://issues.apache.org/jira/browse/KAFKA-6049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16199645#comment-16199645
]
Ted Yu commented on KAFKA-6049:
---
bq. ValueGetters keep calling ValueGetters until
Is there
[
https://issues.apache.org/jira/browse/KAFKA-5988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu resolved KAFKA-5988.
---
Resolution: Won't Fix
> Consider removing StreamThread#STREAM_THREAD_ID_SEQUENCE
> ---
[
https://issues.apache.org/jira/browse/KAFKA-5863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated KAFKA-5863:
--
Description:
Here is the call chain:
{code}
RestServer.httpRequest(reconfigUrl,
[
https://issues.apache.org/jira/browse/KAFKA-6046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16202003#comment-16202003
]
Ted Yu commented on KAFKA-6046:
---
Can someone assign this to me ?
> DeleteRecordsRequest to
[
https://issues.apache.org/jira/browse/KAFKA-5846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16191405#comment-16191405
]
Ted Yu edited comment on KAFKA-5846 at 10/13/17 3:53 PM:
-
Patch lo
[
https://issues.apache.org/jira/browse/KAFKA-6063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16205109#comment-16205109
]
Ted Yu commented on KAFKA-6063:
---
Is this same as KAFKA-6047 ?
> StreamsException is thrown
[
https://issues.apache.org/jira/browse/KAFKA-6047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16205108#comment-16205108
]
Ted Yu commented on KAFKA-6047:
---
Does this require a KIP ?
> Allow retries configuration fo
[
https://issues.apache.org/jira/browse/KAFKA-6024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16205329#comment-16205329
]
Ted Yu commented on KAFKA-6024:
---
Thanks, Siva.
> Consider moving validation in KafkaConsume
[
https://issues.apache.org/jira/browse/KAFKA-5943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated KAFKA-5943:
--
Issue Type: Test (was: Improvement)
> Reduce dependency on mock in connector tests
> --
[
https://issues.apache.org/jira/browse/KAFKA-5027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16209377#comment-16209377
]
Ted Yu commented on KAFKA-5027:
---
If there is dependency among the 'Use ZookeeperClient in' t
[
https://issues.apache.org/jira/browse/KAFKA-5911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu resolved KAFKA-5911.
---
Resolution: Later
> Avoid creation of extra Map for futures in KafkaAdminClient
>
[
https://issues.apache.org/jira/browse/KAFKA-6086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16210291#comment-16210291
]
Ted Yu commented on KAFKA-6086:
---
Normally there is no need to put the KIP number in the subj
[
https://issues.apache.org/jira/browse/KAFKA-6085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16210527#comment-16210527
]
Ted Yu commented on KAFKA-6085:
---
{code}
final ConsumerRecords records = pollRequests
[
https://issues.apache.org/jira/browse/KAFKA-5802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16212069#comment-16212069
]
Ted Yu commented on KAFKA-5802:
---
Thanks for the PR.
> ScramServerCallbackHandler#handle sho
[
https://issues.apache.org/jira/browse/KAFKA-6100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16213140#comment-16213140
]
Ted Yu commented on KAFKA-6100:
---
Can you paste the stack trace (by clicking Debug button) ?
[
https://issues.apache.org/jira/browse/KAFKA-6101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated KAFKA-6101:
--
Attachment: 6101.v1.txt
> Reconnecting to broker does not exponentially backoff
> --
[
https://issues.apache.org/jira/browse/KAFKA-6101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated KAFKA-6101:
--
Attachment: (was: 6101.v1.txt)
> Reconnecting to broker does not exponentially backoff
> ---
[
https://issues.apache.org/jira/browse/KAFKA-6101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated KAFKA-6101:
--
Attachment: 6101.v2.txt
> Reconnecting to broker does not exponentially backoff
> --
[
https://issues.apache.org/jira/browse/KAFKA-6101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated KAFKA-6101:
--
Attachment: 6101.v3.txt
> Reconnecting to broker does not exponentially backoff
> --
[
https://issues.apache.org/jira/browse/KAFKA-5946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated KAFKA-5946:
--
Description:
During the development of KAFKA-5657, there were several iterations where
method call didn't match
[
https://issues.apache.org/jira/browse/KAFKA-5846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16191405#comment-16191405
]
Ted Yu edited comment on KAFKA-5846 at 10/23/17 5:21 PM:
-
Patch lo
Ted Yu created KAFKA-6109:
-
Summary: ResetIntegrationTest may fail due to
IllegalArgumentException
Key: KAFKA-6109
URL: https://issues.apache.org/jira/browse/KAFKA-6109
Project: Kafka
Issue Type: Te
[
https://issues.apache.org/jira/browse/KAFKA-6074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16216171#comment-16216171
]
Ted Yu commented on KAFKA-6074:
---
In ReplicationUtils#propagateIsrChanges() (called by
Repli
1 - 100 of 532 matches
Mail list logo
