[jira] [Commented] (KAFKA-6258) SSLTransportLayer should keep reading from socket until either the buffer is full or the socket has no more data

[ https://issues.apache.org/jira/browse/KAFKA-6258?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16262082#comment-16262082 ] ASF GitHub Bot commented on KAFKA-6258: --- GitHub user lindong28 opened a pull request

[jira] [Created] (KAFKA-6258) SSLTransportLayer should keep reading from socket until either the buffer is full or the socket has no more data

Dong Lin created KAFKA-6258: --- Summary: SSLTransportLayer should keep reading from socket until either the buffer is full or the socket has no more data Key: KAFKA-6258 URL: https://issues.apache.org/jira/browse/KAFKA-62

[jira] [Issue Comment Deleted] (KAFKA-6250) Kafka Connect requires permission to create internal topics even if they exist

[ https://issues.apache.org/jira/browse/KAFKA-6250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gavrie Philipson updated KAFKA-6250: Comment: was deleted (was: This PR fixes the issue: https://github.com/confluentinc/kafka/pu

[jira] [Commented] (KAFKA-6250) Kafka Connect requires permission to create internal topics even if they exist

[ https://issues.apache.org/jira/browse/KAFKA-6250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16262060#comment-16262060 ] ASF GitHub Bot commented on KAFKA-6250: --- GitHub user gavrie opened a pull request:

[jira] [Updated] (KAFKA-6138) Simplify StreamsBuilder#addGlobalStore

[ https://issues.apache.org/jira/browse/KAFKA-6138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6138: --- Description: {{StreamsBuilder#addGlobalStore}} is conceptually a 1:1 copy of {{Topology#addGl

[jira] [Created] (KAFKA-6257) KafkaConsumer was hung when bootstrap servers was not existed

Brian Clark created KAFKA-6257: -- Summary: KafkaConsumer was hung when bootstrap servers was not existed Key: KAFKA-6257 URL: https://issues.apache.org/jira/browse/KAFKA-6257 Project: Kafka Issu

[jira] [Commented] (KAFKA-6138) Simplify StreamsBuilder#addGlobalStore

[ https://issues.apache.org/jira/browse/KAFKA-6138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16261877#comment-16261877 ] Guozhang Wang commented on KAFKA-6138: -- [~panuwat.anawatmongkhon] I have assigned the

[jira] [Assigned] (KAFKA-6138) Simplify StreamsBuilder#addGlobalStore

[ https://issues.apache.org/jira/browse/KAFKA-6138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-6138: Assignee: Panuwat Anawatmongkhon > Simplify StreamsBuilder#addGlobalStore > ---

[jira] [Commented] (KAFKA-6214) Using standby replicas with an in memory state store causes Streams to crash

[ https://issues.apache.org/jira/browse/KAFKA-6214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16261844#comment-16261844 ] ASF GitHub Bot commented on KAFKA-6214: --- Github user asfgit closed the pull request

[jira] [Resolved] (KAFKA-6214) Using standby replicas with an in memory state store causes Streams to crash

[ https://issues.apache.org/jira/browse/KAFKA-6214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6214. -- Resolution: Fixed Fix Version/s: 1.0.1 1.1.0 Issue resolved by pull re

[jira] [Created] (KAFKA-6256) Flaky Unit test: KStreamKTableJoinIntegrationTest.shouldCountClicksPerRegionWithNonZeroByteCache

Matthias J. Sax created KAFKA-6256: -- Summary: Flaky Unit test: KStreamKTableJoinIntegrationTest.shouldCountClicksPerRegionWithNonZeroByteCache Key: KAFKA-6256 URL: https://issues.apache.org/jira/browse/KAFKA-6256

[jira] [Commented] (KAFKA-6255) Add ProduceBench to Trogdor

[ https://issues.apache.org/jira/browse/KAFKA-6255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16261819#comment-16261819 ] ASF GitHub Bot commented on KAFKA-6255: --- GitHub user cmccabe opened a pull request:

[jira] [Created] (KAFKA-6255) Add ProduceBench to Trogdor

Colin P. McCabe created KAFKA-6255: -- Summary: Add ProduceBench to Trogdor Key: KAFKA-6255 URL: https://issues.apache.org/jira/browse/KAFKA-6255 Project: Kafka Issue Type: Sub-task

[jira] [Commented] (KAFKA-4115) Grow default heap settings for distributed Connect from 256M to 1G

[ https://issues.apache.org/jira/browse/KAFKA-4115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16261721#comment-16261721 ] ASF GitHub Bot commented on KAFKA-4115: --- Github user asfgit closed the pull request

[jira] [Commented] (KAFKA-3073) KafkaConnect should support regular expression for topics

[ https://issues.apache.org/jira/browse/KAFKA-3073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16261716#comment-16261716 ] ASF GitHub Bot commented on KAFKA-3073: --- Github user asfgit closed the pull request

[jira] [Created] (KAFKA-6254) Introduce Incremental FetchRequests to Increase Partition Scalability

Colin P. McCabe created KAFKA-6254: -- Summary: Introduce Incremental FetchRequests to Increase Partition Scalability Key: KAFKA-6254 URL: https://issues.apache.org/jira/browse/KAFKA-6254 Project: Kafk

[jira] [Created] (KAFKA-6253) Improve sink connector topic regex validation

Ewen Cheslack-Postava created KAFKA-6253: Summary: Improve sink connector topic regex validation Key: KAFKA-6253 URL: https://issues.apache.org/jira/browse/KAFKA-6253 Project: Kafka I

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

[ https://issues.apache.org/jira/browse/KAFKA-5842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16261623#comment-16261623 ] Ewen Cheslack-Postava commented on KAFKA-5842: -- I've also now seen this in a

[jira] [Commented] (KAFKA-6168) Connect Schema comparison is slow for large schemas

[ https://issues.apache.org/jira/browse/KAFKA-6168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16261596#comment-16261596 ] ASF GitHub Bot commented on KAFKA-6168: --- Github user asfgit closed the pull request

[jira] [Resolved] (KAFKA-6168) Connect Schema comparison is slow for large schemas

[ https://issues.apache.org/jira/browse/KAFKA-6168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-6168. -- Resolution: Fixed Fix Version/s: 1.1.0 Issue resolved by pull request 417

[jira] [Commented] (KAFKA-6249) Interactive query downtime when node goes down even with standby replicas

[ https://issues.apache.org/jira/browse/KAFKA-6249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16261575#comment-16261575 ] Matthias J. Sax commented on KAFKA-6249: Thanks for giving feedback :) It seems th

[jira] [Comment Edited] (KAFKA-6248) Enable configuration of internal topics of Kafka Streams applications

[ https://issues.apache.org/jira/browse/KAFKA-6248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16260892#comment-16260892 ] Bill Bejeck edited comment on KAFKA-6248 at 11/21/17 8:59 PM: --

[jira] [Commented] (KAFKA-6205) Have State Stores Restore Before Initializing Toplogy

[ https://issues.apache.org/jira/browse/KAFKA-6205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16261390#comment-16261390 ] Matthias J. Sax commented on KAFKA-6205: In {{1.0}} you can register a {{StateRest

[jira] [Commented] (KAFKA-6193) ReassignPartitionsClusterTest.shouldPerformMultipleReassignmentOperationsOverVariousTopics fails sometimes

[ https://issues.apache.org/jira/browse/KAFKA-6193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16261232#comment-16261232 ] Vahid Hashemian commented on KAFKA-6193: Another instance of this failure that hap

[jira] [Commented] (KAFKA-6251) Update kafka-configs.sh to use the new AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-6251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16261197#comment-16261197 ] Rajini Sivaram commented on KAFKA-6251: --- I think KAFKA-5561 is updating only {{Topic

[jira] [Updated] (KAFKA-6252) A metric named 'XX' already exists, can't register another one.

[ https://issues.apache.org/jira/browse/KAFKA-6252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexis Sellier updated KAFKA-6252: -- Description: When a connector crashes, It cannot be restarted and an exception like this is thr

[jira] [Created] (KAFKA-6252) A metric named 'XX' already exists, can't register another one.

Alexis Sellier created KAFKA-6252: - Summary: A metric named 'XX' already exists, can't register another one. Key: KAFKA-6252 URL: https://issues.apache.org/jira/browse/KAFKA-6252 Project: Kafka

[jira] [Commented] (KAFKA-6251) Update kafka-configs.sh to use the new AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-6251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16261042#comment-16261042 ] Tom Bentley commented on KAFKA-6251: This is a dupe of https://issues.apache.org/jira/

[jira] [Updated] (KAFKA-4893) async topic deletion conflicts with max topic length

[ https://issues.apache.org/jira/browse/KAFKA-4893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian updated KAFKA-4893: --- Fix Version/s: 1.1.0 > async topic deletion conflicts with max topic length >

[jira] [Created] (KAFKA-6251) Update kafka-configs.sh to use the new AdminClient

Rajini Sivaram created KAFKA-6251: - Summary: Update kafka-configs.sh to use the new AdminClient Key: KAFKA-6251 URL: https://issues.apache.org/jira/browse/KAFKA-6251 Project: Kafka Issue Type

[jira] [Commented] (KAFKA-5407) Mirrormaker dont start after upgrade

[ https://issues.apache.org/jira/browse/KAFKA-5407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16260957#comment-16260957 ] Ismael Juma commented on KAFKA-5407: It does look intentional, as you say, but not sur

[jira] [Commented] (KAFKA-6250) Kafka Connect requires permission to create internal topics even if they exist

[ https://issues.apache.org/jira/browse/KAFKA-6250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16260952#comment-16260952 ] Gavrie Philipson commented on KAFKA-6250: - This PR fixes the issue: https://github

[jira] [Created] (KAFKA-6250) Kafka Connect requires permission to create internal topics even if they exist

Gavrie Philipson created KAFKA-6250: --- Summary: Kafka Connect requires permission to create internal topics even if they exist Key: KAFKA-6250 URL: https://issues.apache.org/jira/browse/KAFKA-6250 Pr

[jira] [Updated] (KAFKA-5946) Give connector method parameter better name

[ 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

[jira] [Commented] (KAFKA-6232) SaslSslAdminClientIntegrationTest sometimes fails

[ https://issues.apache.org/jira/browse/KAFKA-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16260942#comment-16260942 ] Ted Yu commented on KAFKA-6232: --- >From https://builds.apache.org/job/kafka-trunk-jdk8/2225/t

[jira] [Commented] (KAFKA-5407) Mirrormaker dont start after upgrade

[ https://issues.apache.org/jira/browse/KAFKA-5407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16260939#comment-16260939 ] Manikumar commented on KAFKA-5407: -- [~ijuma] Sure, I can work on it. But If i remember

[jira] [Comment Edited] (KAFKA-6205) Have State Stores Restore Before Initializing Toplogy

[ https://issues.apache.org/jira/browse/KAFKA-6205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16260816#comment-16260816 ] Rainer Guessner edited comment on KAFKA-6205 at 11/21/17 3:53 PM: --

[jira] [Commented] (KAFKA-6248) Enable configuration of internal topics of Kafka Streams applications

[ https://issues.apache.org/jira/browse/KAFKA-6248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16260892#comment-16260892 ] Bill Bejeck commented on KAFKA-6248: Hi [~timvanlaer] Take a look at [KIP-173|https

[jira] [Commented] (KAFKA-5407) Mirrormaker dont start after upgrade

[ https://issues.apache.org/jira/browse/KAFKA-5407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16260885#comment-16260885 ] Ismael Juma commented on KAFKA-5407: A couple of things: 1. We should file a separate

[jira] [Comment Edited] (KAFKA-5473) handle ZK session expiration properly when a new session can't be established

[ https://issues.apache.org/jira/browse/KAFKA-5473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16260874#comment-16260874 ] Ismael Juma edited comment on KAFKA-5473 at 11/21/17 3:06 PM: --

[jira] [Commented] (KAFKA-5473) handle ZK session expiration properly when a new session can't be established

[ https://issues.apache.org/jira/browse/KAFKA-5473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16260874#comment-16260874 ] Ismael Juma commented on KAFKA-5473: [~junrao] [~prasincs], I've closed a bunch of JIR

[jira] [Resolved] (KAFKA-4871) Kafka doesn't respect TTL on Zookeeper hostname - crash if zookeeper IP changes

[ https://issues.apache.org/jira/browse/KAFKA-4871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-4871. Resolution: Duplicate Duplicate of KAFKA-5473. > Kafka doesn't respect TTL on Zookeeper hostname -

[jira] [Commented] (KAFKA-3984) Broker doesn't retry reconnecting to an expired Zookeeper connection

[ https://issues.apache.org/jira/browse/KAFKA-3984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16260863#comment-16260863 ] Ismael Juma commented on KAFKA-3984: [~dkuldeep11], we expect to have a fix for 1.1.0

[jira] [Resolved] (KAFKA-4041) kafka unable to reconnect to zookeeper behind an ELB

[ https://issues.apache.org/jira/browse/KAFKA-4041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-4041. Resolution: Duplicate > kafka unable to reconnect to zookeeper behind an ELB > -

[jira] [Reopened] (KAFKA-4041) kafka unable to reconnect to zookeeper behind an ELB

[ https://issues.apache.org/jira/browse/KAFKA-4041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma reopened KAFKA-4041: > kafka unable to reconnect to zookeeper behind an ELB > ---

[jira] [Resolved] (KAFKA-4041) kafka unable to reconnect to zookeeper behind an ELB

[ https://issues.apache.org/jira/browse/KAFKA-4041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-4041. Resolution: Fixed Marking as a duplicate of KAFKA-5473. In that JIRA, we will recreate the `ZooKeep

[jira] [Resolved] (KAFKA-2193) Intermittent network + DNS issues can cause brokers to permanently drop out of a cluster

[ https://issues.apache.org/jira/browse/KAFKA-2193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-2193. Resolution: Duplicate Duplicate of KAFKA-5473. > Intermittent network + DNS issues can cause broker

[jira] [Resolved] (KAFKA-2864) Bad zookeeper host causes broker to shutdown uncleanly and stall producers

[ https://issues.apache.org/jira/browse/KAFKA-2864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-2864. Resolution: Duplicate Duplicate of KAFKA-5473. > Bad zookeeper host causes broker to shutdown uncle

[jira] [Comment Edited] (KAFKA-6205) Have State Stores Restore Before Initializing Toplogy

[ https://issues.apache.org/jira/browse/KAFKA-6205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16260816#comment-16260816 ] Rainer Guessner edited comment on KAFKA-6205 at 11/21/17 2:55 PM: --

[jira] [Resolved] (KAFKA-6247) Fix system test dependency issues

[ https://issues.apache.org/jira/browse/KAFKA-6247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-6247. Resolution: Fixed Assignee: Colin P. McCabe Fix Version/s: 1.1.0 > Fix system test d

[jira] [Commented] (KAFKA-6205) Have State Stores Restore Before Initializing Toplogy

[ https://issues.apache.org/jira/browse/KAFKA-6205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16260816#comment-16260816 ] Rainer Guessner commented on KAFKA-6205: Or can there at least be a "ready" call o

[jira] [Created] (KAFKA-6249) Interactive query downtime when node goes down even with standby replicas

Charles Crain created KAFKA-6249: Summary: Interactive query downtime when node goes down even with standby replicas Key: KAFKA-6249 URL: https://issues.apache.org/jira/browse/KAFKA-6249 Project: Kafk

[jira] [Commented] (KAFKA-6247) Fix system test dependency issues

[ https://issues.apache.org/jira/browse/KAFKA-6247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16260811#comment-16260811 ] ASF GitHub Bot commented on KAFKA-6247: --- Github user asfgit closed the pull request

[jira] [Created] (KAFKA-6248) Enable configuration of internal topics of Kafka Streams applications

Tim Van Laer created KAFKA-6248: --- Summary: Enable configuration of internal topics of Kafka Streams applications Key: KAFKA-6248 URL: https://issues.apache.org/jira/browse/KAFKA-6248 Project: Kafka

[jira] [Commented] (KAFKA-5631) Use Jackson for serialising to JSON

[ https://issues.apache.org/jira/browse/KAFKA-5631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16260652#comment-16260652 ] Umesh Chaudhary commented on KAFKA-5631: [~seglo] thanks for the ping. Sorry, I am

[jira] [Comment Edited] (KAFKA-6195) DNS alias support for secured connections

[ https://issues.apache.org/jira/browse/KAFKA-6195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16260628#comment-16260628 ] Jonathan Skrzypek edited comment on KAFKA-6195 at 11/21/17 12:03 PM: ---

[jira] [Comment Edited] (KAFKA-6195) DNS alias support for secured connections

[ https://issues.apache.org/jira/browse/KAFKA-6195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16260628#comment-16260628 ] Jonathan Skrzypek edited comment on KAFKA-6195 at 11/21/17 12:02 PM: ---

[jira] [Commented] (KAFKA-6195) DNS alias support for secured connections

[ https://issues.apache.org/jira/browse/KAFKA-6195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16260628#comment-16260628 ] Jonathan Skrzypek commented on KAFKA-6195: -- Thanks for taking a look ! Yes, your

[jira] [Commented] (KAFKA-6195) DNS alias support for secured connections

[ https://issues.apache.org/jira/browse/KAFKA-6195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16260618#comment-16260618 ] Ismael Juma commented on KAFKA-6195: [~jonathanskrzypek], for option 2, do you mean so

[jira] [Commented] (KAFKA-6195) DNS alias support for secured connections

[ https://issues.apache.org/jira/browse/KAFKA-6195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16260607#comment-16260607 ] Jonathan Skrzypek commented on KAFKA-6195: -- [~rsivaram] I think it's possible to

[jira] [Commented] (KAFKA-3702) SslTransportLayer.close() does not shutdown gracefully

[ https://issues.apache.org/jira/browse/KAFKA-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16260482#comment-16260482 ] Lionel Cons commented on KAFKA-3702: FWIW, this has been discussed at https://www.mai