[jira] [Created] (KAFKA-7236) Add --critical-partitions option to describe topics command

2018-08-02 Thread Kevin Lu (JIRA)
Kevin Lu created KAFKA-7236: --- Summary: Add --critical-partitions option to describe topics command Key: KAFKA-7236 URL: https://issues.apache.org/jira/browse/KAFKA-7236 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-7236) Add --critical-partitions option to describe topics command

2018-08-02 Thread Kevin Lu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Lu updated KAFKA-7236: Description: [KIP-351|https://cwiki.apache.org/confluence/display/KAFKA/KIP-351%3A+Add+--critical-partition

[jira] [Commented] (KAFKA-7225) Kafka Connect ConfigProvider not invoked before validation

2018-08-02 Thread Nacho Munoz (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16566500#comment-16566500 ] Nacho Munoz commented on KAFKA-7225: [~rayokota] I'm quite disappointed with your beh

[jira] [Created] (KAFKA-7237) Add explicit fatal marker to fatal error messages

2018-08-02 Thread Rajini Sivaram (JIRA)
Rajini Sivaram created KAFKA-7237: - Summary: Add explicit fatal marker to fatal error messages Key: KAFKA-7237 URL: https://issues.apache.org/jira/browse/KAFKA-7237 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-7237) Add explicit fatal marker to fatal error messages

2018-08-02 Thread Rajini Sivaram (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-7237: -- Description: We currently use FATAL markers for fatal error messages in core. But only logback

[jira] [Commented] (KAFKA-7237) Add explicit fatal marker to fatal error messages

2018-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16566578#comment-16566578 ] ASF GitHub Bot commented on KAFKA-7237: --- stanislavkozlovski opened a new pull reque

[jira] [Assigned] (KAFKA-7237) Add explicit fatal marker to fatal error messages

2018-08-02 Thread Stanislav Kozlovski (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski reassigned KAFKA-7237: -- Assignee: Stanislav Kozlovski > Add explicit fatal marker to fatal error messa

[jira] [Commented] (KAFKA-7190) Under low traffic conditions purging repartition topics cause WARN statements about UNKNOWN_PRODUCER_ID

2018-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1658#comment-1658 ] ASF GitHub Bot commented on KAFKA-7190: --- lambdaliu opened a new pull request #5448:

[jira] [Created] (KAFKA-7238) Producer can't update Metadata when two brokers break down and restart the first one

2018-08-02 Thread little brother ma (JIRA)
little brother ma created KAFKA-7238: Summary: Producer can't update Metadata when two brokers break down and restart the first one Key: KAFKA-7238 URL: https://issues.apache.org/jira/browse/KAFKA-7238

[jira] [Commented] (KAFKA-7225) Kafka Connect ConfigProvider not invoked before validation

2018-08-02 Thread Robert Yokota (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16566907#comment-16566907 ] Robert Yokota commented on KAFKA-7225: -- Hi [~nachomdo], thanks for finding and loggi

[jira] [Commented] (KAFKA-7225) Kafka Connect ConfigProvider not invoked before validation

2018-08-02 Thread Robert Yokota (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16566913#comment-16566913 ] Robert Yokota commented on KAFKA-7225: -- If you want, I can still close my PR so you

[jira] [Commented] (KAFKA-7225) Kafka Connect ConfigProvider not invoked before validation

2018-08-02 Thread Nacho Munoz (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16566915#comment-16566915 ] Nacho Munoz commented on KAFKA-7225: No worries. Thanks for fixing it so quickly!  >

[jira] [Commented] (KAFKA-7225) Kafka Connect ConfigProvider not invoked before validation

2018-08-02 Thread Robert Yokota (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16566918#comment-16566918 ] Robert Yokota commented on KAFKA-7225: -- Thanks [~nachomdo]!  Again, I really appreci

[jira] [Commented] (KAFKA-7225) Kafka Connect ConfigProvider not invoked before validation

2018-08-02 Thread Nacho Munoz (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16566917#comment-16566917 ] Nacho Munoz commented on KAFKA-7225: Thank you! no need to close your PR, there are p

[jira] [Issue Comment Deleted] (KAFKA-7158) Duplicates when searching kafka stream state store with caching

2018-08-02 Thread Christian Henry (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Christian Henry updated KAFKA-7158: --- Comment: was deleted (was: Sorry for the delay, finally got some time to provide a minimal ex

[jira] [Commented] (KAFKA-7158) Duplicates when searching kafka stream state store with caching

2018-08-02 Thread Christian Henry (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16567054#comment-16567054 ] Christian Henry commented on KAFKA-7158: Sorry for the delay, finally got some ti

[jira] [Commented] (KAFKA-7158) Duplicates when searching kafka stream state store with caching

2018-08-02 Thread Christian Henry (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16567072#comment-16567072 ] Christian Henry commented on KAFKA-7158: Sorry for the delay, finally got some ti

[jira] [Commented] (KAFKA-7233) InMemoryKeyValueStore is not thread-safe for Interactive Queries

2018-08-02 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16567289#comment-16567289 ] Matthias J. Sax commented on KAFKA-7233: Can you clarify? The implementation of t

[jira] [Commented] (KAFKA-7231) NetworkClient.newClientRequest() ignores custom request timeout in favor of the default

2018-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16567294#comment-16567294 ] ASF GitHub Bot commented on KAFKA-7231: --- hachikuji closed pull request #5444: KAFKA

[jira] [Created] (KAFKA-7239) Kafka Connect secret externalization not working

2018-08-02 Thread satyanarayan komandur (JIRA)
satyanarayan komandur created KAFKA-7239: Summary: Kafka Connect secret externalization not working Key: KAFKA-7239 URL: https://issues.apache.org/jira/browse/KAFKA-7239 Project: Kafka

[jira] [Updated] (KAFKA-7218) Log thread names & ids when KafkaConsumer throws ConcurrentModificationException

2018-08-02 Thread Kevin Lu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Lu updated KAFKA-7218: Component/s: (was: log) logging > Log thread names & ids when KafkaConsumer throws >

[jira] [Updated] (KAFKA-6757) Log runtime exception in case of server startup errors

2018-08-02 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-6757: -- Component/s: (was: log) logging > Log runtime exception in case of server startup

[jira] [Updated] (KAFKA-6947) Mirrormaker Closing producer due to send failure

2018-08-02 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-6947: -- Component/s: mirrormaker > Mirrormaker Closing producer due to send failure > -

[jira] [Updated] (KAFKA-5138) MirrorMaker doesn't exit on send failure occasionally

2018-08-02 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-5138: -- Component/s: mirrormaker > MirrorMaker doesn't exit on send failure occasionally >

[jira] [Updated] (KAFKA-4088) Add regression check for KAFKA-4073

2018-08-02 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-4088: -- Component/s: mirrormaker > Add regression check for KAFKA-4073 > --- >

[jira] [Updated] (KAFKA-3848) Mirror Maker sometimes fails to mirror first batch of messages

2018-08-02 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-3848: -- Component/s: mirrormaker > Mirror Maker sometimes fails to mirror first batch of messages > ---

[jira] [Updated] (KAFKA-6021) run kafka-mirror-maker.sh in daemon mode

2018-08-02 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-6021: -- Component/s: tools mirrormaker > run kafka-mirror-maker.sh in daemon mode > --

[jira] [Updated] (KAFKA-2759) Mirror maker can leave gaps of missing messages if the process dies after a partition is reset and before the first offset commit

2018-08-02 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-2759: -- Component/s: mirrormaker > Mirror maker can leave gaps of missing messages if the process dies after a

[jira] [Updated] (KAFKA-658) Implement "Exact Mirroring" functionality in mirror maker

2018-08-02 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-658: - Component/s: mirrormaker > Implement "Exact Mirroring" functionality in mirror maker > ---

[jira] [Updated] (KAFKA-1043) Time-consuming FetchRequest could block other request in the response queue

2018-08-02 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-1043: -- Component/s: mirrormaker > Time-consuming FetchRequest could block other request in the response queue

[jira] [Commented] (KAFKA-1696) Kafka should be able to generate Hadoop delegation tokens

2018-08-02 Thread Mingjie Tang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16567428#comment-16567428 ] Mingjie Tang commented on KAFKA-1696: - ping, does this GA or not? > Kafka should be

[jira] [Comment Edited] (KAFKA-1696) Kafka should be able to generate Hadoop delegation tokens

2018-08-02 Thread Mingjie Tang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16567428#comment-16567428 ] Mingjie Tang edited comment on KAFKA-1696 at 8/2/18 7:59 PM: -

[jira] [Commented] (KAFKA-6761) Reduce Kafka Streams Footprint

2018-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16567441#comment-16567441 ] ASF GitHub Bot commented on KAFKA-6761: --- bbejeck opened a new pull request #5451: K

[jira] [Created] (KAFKA-7240) -total metrics in Streams are incorrect

2018-08-02 Thread Sam Lendle (JIRA)
Sam Lendle created KAFKA-7240: - Summary: -total metrics in Streams are incorrect Key: KAFKA-7240 URL: https://issues.apache.org/jira/browse/KAFKA-7240 Project: Kafka Issue Type: Bug Com

[jira] [Updated] (KAFKA-6915) MirrorMaker: avoid duplicates when source cluster is unreachable for more than session.timeout.ms

2018-08-02 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-6915: -- Component/s: mirrormaker > MirrorMaker: avoid duplicates when source cluster is unreachable for more >

[jira] [Updated] (KAFKA-6915) MirrorMaker: avoid duplicates when source cluster is unreachable for more than session.timeout.ms

2018-08-02 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-6915: -- Labels: (was: mirror-maker) > MirrorMaker: avoid duplicates when source cluster is unreachable for mo

[jira] [Updated] (KAFKA-6216) kafka logs for misconfigured ssl clients are unhelpful

2018-08-02 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-6216: -- Component/s: logging clients > kafka logs for misconfigured ssl clients are unhelpful

[jira] [Updated] (KAFKA-6165) Kafka Brokers goes down with outOfMemoryError.

2018-08-02 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-6165: -- Component/s: logging > Kafka Brokers goes down with outOfMemoryError. > ---

[jira] [Updated] (KAFKA-6584) Session expiration concurrent with ZooKeeper leadership failover may lead to broker registration failure

2018-08-02 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-6584: -- Component/s: zkclient > Session expiration concurrent with ZooKeeper leadership failover may lead to >

[jira] [Updated] (KAFKA-4277) creating ephemeral node already exist

2018-08-02 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-4277: -- Component/s: zkclient > creating ephemeral node already exist > - >

[jira] [Commented] (KAFKA-6761) Reduce Kafka Streams Footprint

2018-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16567498#comment-16567498 ] ASF GitHub Bot commented on KAFKA-6761: --- bbejeck opened a new pull request #5453: M

[jira] [Commented] (KAFKA-7233) InMemoryKeyValueStore is not thread-safe for Interactive Queries

2018-08-02 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16567505#comment-16567505 ] Guozhang Wang commented on KAFKA-7233: -- I think it may be due to the cache layer, no

[jira] [Resolved] (KAFKA-7125) Calling StreamsBuilderbuilder.build().describe() causes java.util.NoSuchElementException: null

2018-08-02 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-7125. -- Resolution: Won't Fix > Calling StreamsBuilderbuilder.build().describe() causes > java.util.No

[jira] [Commented] (KAFKA-7125) Calling StreamsBuilderbuilder.build().describe() causes java.util.NoSuchElementException: null

2018-08-02 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16567507#comment-16567507 ] Guozhang Wang commented on KAFKA-7125: -- Thanks for the update [~Ahto]! > Calling St

[jira] [Updated] (KAFKA-7175) Make version checking logic more flexible in streams_upgrade_test.py

2018-08-02 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-7175: - Labels: newbie++ (was: ) > Make version checking logic more flexible in streams_upgrade_test.py

[jira] [Resolved] (KAFKA-7049) InternalTopicIntegrationTest sometimes fails

2018-08-02 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-7049. -- Resolution: Cannot Reproduce > InternalTopicIntegrationTest sometimes fails > -

[jira] [Resolved] (KAFKA-7228) DeadLetterQueue throws a NullPointerException

2018-08-02 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-7228. -- Resolution: Fixed > DeadLetterQueue throws a NullPointerException > ---

[jira] [Commented] (KAFKA-7049) InternalTopicIntegrationTest sometimes fails

2018-08-02 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16567512#comment-16567512 ] Guozhang Wang commented on KAFKA-7049: -- It maybe fixed as part of https://github.co

[jira] [Commented] (KAFKA-7228) DeadLetterQueue throws a NullPointerException

2018-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16567511#comment-16567511 ] ASF GitHub Bot commented on KAFKA-7228: --- ewencp closed pull request #5440: KAFKA-72

[jira] [Updated] (KAFKA-5536) Tools splitted between Java and Scala implementation

2018-08-02 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-5536: -- Component/s: tools clients > Tools splitted between Java and Scala implementation > --

[jira] [Updated] (KAFKA-4928) Add integration test for DumpLogSegments

2018-08-02 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-4928: -- Component/s: tools log > Add integration test for DumpLogSegments > --

[jira] [Updated] (KAFKA-4479) Streams tests should pass without hardcoded Time.SYSTEM in GroupCoordinator

2018-08-02 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-4479: -- Component/s: unit tests streams > Streams tests should pass without hardcoded Time.SYS

[jira] [Updated] (KAFKA-4164) Kafka produces excessive logs when publishing message to non-existent topic

2018-08-02 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-4164: -- Component/s: logging > Kafka produces excessive logs when publishing message to non-existent topic > --

[jira] [Resolved] (KAFKA-4101) java.lang.IllegalStateException in org.apache.kafka.common.network.Selector.channelOrFail

2018-08-02 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang resolved KAFKA-4101. --- Resolution: Duplicate > java.lang.IllegalStateException in > org.apache.kafka.common.network.Selecto

[jira] [Updated] (KAFKA-3468) Java clients never fail when bootstrap uses incorrect port

2018-08-02 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-3468: -- Component/s: clients > Java clients never fail when bootstrap uses incorrect port > ---

[jira] [Updated] (KAFKA-3115) Remove locking in metrics package

2018-08-02 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-3115: -- Component/s: metrics > Remove locking in metrics package > - > >

[jira] [Updated] (KAFKA-3274) Document command line tools

2018-08-02 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-3274: -- Component/s: tools documentation > Document command line tools > -

[jira] [Updated] (KAFKA-3385) Need to log "Rejected connection" as WARNING message

2018-08-02 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-3385: -- Component/s: logging > Need to log "Rejected connection" as WARNING message > -

[jira] [Updated] (KAFKA-3428) Remove metadata sync bottleneck from mirrormaker's producer

2018-08-02 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-3428: -- Component/s: mirrormaker > Remove metadata sync bottleneck from mirrormaker's producer > --

[jira] [Commented] (KAFKA-4479) Streams tests should pass without hardcoded Time.SYSTEM in GroupCoordinator

2018-08-02 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16567529#comment-16567529 ] Matthias J. Sax commented on KAFKA-4479: Just re-reading the description: Streams

[jira] [Updated] (KAFKA-4668) Mirrormaker should default to auto.offset.reset=earliest

2018-08-02 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-4668: -- Component/s: mirrormaker > Mirrormaker should default to auto.offset.reset=earliest > -

[jira] [Updated] (KAFKA-3320) Add successful acks verification to ProduceConsumeValidateTest

2018-08-02 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-3320: -- Component/s: unit tests > Add successful acks verification to ProduceConsumeValidateTest >

[jira] [Commented] (KAFKA-4479) Streams tests should pass without hardcoded Time.SYSTEM in GroupCoordinator

2018-08-02 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16567535#comment-16567535 ] Guozhang Wang commented on KAFKA-4479: -- lgtm. > Streams tests should pass without h

[jira] [Commented] (KAFKA-7175) Make version checking logic more flexible in streams_upgrade_test.py

2018-08-02 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16567543#comment-16567543 ] Ray Chiang commented on KAFKA-7175: --- I'll take a bash at this one. > Make version chec

[jira] [Assigned] (KAFKA-7175) Make version checking logic more flexible in streams_upgrade_test.py

2018-08-02 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang reassigned KAFKA-7175: - Assignee: Ray Chiang > Make version checking logic more flexible in streams_upgrade_test.py > --

[jira] [Commented] (KAFKA-7197) Release a milestone build for Scala 2.13.0 M3

2018-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16567555#comment-16567555 ] ASF GitHub Bot commented on KAFKA-7197: --- dejan2609 opened a new pull request #5454:

[jira] [Commented] (KAFKA-7158) Duplicates when searching kafka stream state store with caching

2018-08-02 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16567559#comment-16567559 ] Guozhang Wang commented on KAFKA-7158: -- Thank you [~cah6]. I will try it out. > Dup

[jira] [Updated] (KAFKA-5883) Run tests on Java 9 with –illegal-access=deny

2018-08-02 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-5883: -- Component/s: unit tests > Run tests on Java 9 with –illegal-access=deny > -

[jira] [Updated] (KAFKA-5842) QueryableStateIntegrationTest may fail with JDK 7

2018-08-02 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-5842: -- Component/s: unit tests > QueryableStateIntegrationTest may fail with JDK 7 > -

[jira] [Updated] (KAFKA-5860) Prevent non-consecutive partition ids

2018-08-02 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-5860: -- Component/s: admin > Prevent non-consecutive partition ids > - > >

[jira] [Updated] (KAFKA-5460) Documentation on website uses word-breaks resulting in confusion

2018-08-02 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-5460: -- Component/s: documentation > Documentation on website uses word-breaks resulting in confusion > ---

[jira] [Updated] (KAFKA-5307) Concurrent offset commit on same partition may result in inconsistent cache

2018-08-02 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-5307: -- Component/s: offset manager > Concurrent offset commit on same partition may result in inconsistent cac

[jira] [Updated] (KAFKA-5421) Getting InvalidRecordException

2018-08-02 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-5421: -- Component/s: log > Getting InvalidRecordException > -- > >

[jira] [Updated] (KAFKA-7240) -total metrics in Streams are incorrect

2018-08-02 Thread Sam Lendle (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sam Lendle updated KAFKA-7240: -- Description: I noticed the values of total metrics for streams were decreasing periodically when viewe

[jira] [Updated] (KAFKA-6722) SensorAccess.getOrCreate should be more efficient

2018-08-02 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-6722: -- Component/s: metrics > SensorAccess.getOrCreate should be more efficient >

[jira] [Updated] (KAFKA-6660) Monitoring number of messages expired due to retention policy

2018-08-02 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-6660: -- Component/s: metrics log > Monitoring number of messages expired due to retention poli

[jira] [Updated] (KAFKA-7240) -total metrics in Streams are incorrect

2018-08-02 Thread Sam Lendle (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sam Lendle updated KAFKA-7240: -- Description: I noticed the values of total metrics for streams were decreasing periodically when viewe

[jira] [Updated] (KAFKA-6090) Upgrade the Scala recommendation to 2.12

2018-08-02 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-6090: -- Component/s: build > Upgrade the Scala recommendation to 2.12 > ---

[jira] [Updated] (KAFKA-6040) Expose topic size for monitoring

2018-08-02 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-6040: -- Component/s: metrics > Expose topic size for monitoring > > >

[jira] [Updated] (KAFKA-5687) Retention settings are inconsistent between broker and topic

2018-08-02 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-5687: -- Component/s: log > Retention settings are inconsistent between broker and topic > -

[jira] [Commented] (KAFKA-5687) Retention settings are inconsistent between broker and topic

2018-08-02 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16567628#comment-16567628 ] Ray Chiang commented on KAFKA-5687: --- I think there's a misreading in the docs here. Th

[jira] [Updated] (KAFKA-3015) Improve JBOD data balancing

2018-08-02 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-3015: -- Component/s: core > Improve JBOD data balancing > --- > > Key:

[jira] [Updated] (KAFKA-2861) system tests: grep logs for errors as part of validation

2018-08-02 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-2861: -- Component/s: system tests > system tests: grep logs for errors as part of validation >

[jira] [Updated] (KAFKA-3015) Improve JBOD data balancing

2018-08-02 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-3015: -- Component/s: (was: core) log > Improve JBOD data balancing > -

[jira] [Updated] (KAFKA-2569) Kafka should write its metrics to a Kafka topic

2018-08-02 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-2569: -- Component/s: metrics > Kafka should write its metrics to a Kafka topic > --

[jira] [Updated] (KAFKA-1921) Delete offsets for a group with kafka offset storage

2018-08-02 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-1921: -- Component/s: offset manager > Delete offsets for a group with kafka offset storage > --

[jira] [Updated] (KAFKA-1918) System test for ZooKeeper quorum failure scenarios

2018-08-02 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-1918: -- Component/s: system tests > System test for ZooKeeper quorum failure scenarios > --

[jira] [Updated] (KAFKA-1794) Make config and config defaults accessible to clients

2018-08-02 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-1794: -- Component/s: producer config > Make config and config defaults accessible to clients

[jira] [Updated] (KAFKA-1704) Add PartitionConfig besides LogConfig

2018-08-02 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-1704: -- Component/s: config > Add PartitionConfig besides LogConfig > - > >

[jira] [Updated] (KAFKA-1858) Make ServerShutdownTest a bit less flaky

2018-08-02 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-1858: -- Component/s: unit tests > Make ServerShutdownTest a bit less flaky > --

[jira] [Updated] (KAFKA-967) Use key range in ProducerPerformance

2018-08-02 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-967: - Component/s: producer > Use key range in ProducerPerformance > > >

[jira] [Updated] (KAFKA-960) Upgrade Metrics to 3.x

2018-08-02 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-960: - Component/s: metrics > Upgrade Metrics to 3.x > -- > > Key: KAFKA-960

[jira] [Updated] (KAFKA-1122) Kafka can log giant log lines

2018-08-02 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-1122: -- Component/s: logging > Kafka can log giant log lines > - > >

[jira] [Commented] (KAFKA-7240) -total metrics in Streams are incorrect

2018-08-02 Thread Sam Lendle (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16567632#comment-16567632 ] Sam Lendle commented on KAFKA-7240: --- I believe at least part of the issue is in [Strea

[jira] [Updated] (KAFKA-517) Ensure that we escape the metric names if they include user strings

2018-08-02 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-517: - Component/s: metrics > Ensure that we escape the metric names if they include user strings > -

[jira] [Commented] (KAFKA-3514) Stream timestamp computation needs some further thoughts

2018-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16567670#comment-16567670 ] ASF GitHub Bot commented on KAFKA-3514: --- guozhangwang closed pull request #5398: KA

[jira] [Commented] (KAFKA-5587) Processor got uncaught exception: NullPointerException

2018-08-02 Thread lambdaliu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16567718#comment-16567718 ] lambdaliu commented on KAFKA-5587: -- Hi [~rsivaram], I found this issue still appears in

[jira] [Commented] (KAFKA-7233) InMemoryKeyValueStore is not thread-safe for Interactive Queries

2018-08-02 Thread Hashan Gayasri Udugahapattuwa (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16567765#comment-16567765 ] Hashan Gayasri Udugahapattuwa commented on KAFKA-7233: -- [~mjsax] Sor

[jira] [Resolved] (KAFKA-7233) InMemoryKeyValueStore is not thread-safe for Interactive Queries

2018-08-02 Thread Hashan Gayasri Udugahapattuwa (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hashan Gayasri Udugahapattuwa resolved KAFKA-7233. -- Resolution: Invalid The implementation is correct > InMemoryKe

[jira] [Updated] (KAFKA-7233) InMemoryKeyValueStore is not thread-safe for Interactive Queries

2018-08-02 Thread Hashan Gayasri Udugahapattuwa (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hashan Gayasri Udugahapattuwa updated KAFKA-7233: - Description: When querying externally from via the  [ReadOnlyKeyV

  1   2   >