[
https://issues.apache.org/jira/browse/KAFKA-6963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16564863#comment-16564863
]
ASF GitHub Bot commented on KAFKA-6963:
---
rhysmccaig opened a new pull request #5438
[
https://issues.apache.org/jira/browse/KAFKA-3821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16564900#comment-16564900
]
Gunnar Morling commented on KAFKA-3821:
---
One other alternative came to my mind whic
[
https://issues.apache.org/jira/browse/KAFKA-7165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16564932#comment-16564932
]
Jonathan Santilli commented on KAFKA-7165:
--
Sure [~omkreddy] , it makes sense, s
[
https://issues.apache.org/jira/browse/KAFKA-6188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16565055#comment-16565055
]
Peng Peng commented on KAFKA-6188:
--
[~ijuma] I also met this issue when restart Kafka Se
Nacho Munoz created KAFKA-7225:
--
Summary: Kafka Connect ConfigProvider not invoked before validation
Key: KAFKA-7225
URL: https://issues.apache.org/jira/browse/KAFKA-7225
Project: Kafka
Issue Ty
[
https://issues.apache.org/jira/browse/KAFKA-7225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nacho Munoz updated KAFKA-7225:
---
Description:
When trying to register a JDBC connector with externalised secrets (e.g.
connection.pas
[
https://issues.apache.org/jira/browse/KAFKA-5928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Genmao Yu updated KAFKA-5928:
-
Affects Version/s: 1.0.0
> Avoid redundant requests to zookeeper when reassign topic partition
>
[
https://issues.apache.org/jira/browse/KAFKA-5928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Genmao Yu updated KAFKA-5928:
-
Affects Version/s: 2.0.0
> Avoid redundant requests to zookeeper when reassign topic partition
>
Alexandre GRIFFAUT created KAFKA-7226:
-
Summary: kafka-console-consumer.sh doesn't use security.protocol
provided in config file
Key: KAFKA-7226
URL: https://issues.apache.org/jira/browse/KAFKA-7226
Genmao Yu created KAFKA-7227:
Summary: Kafka cluster should has a default rack id if not set
Key: KAFKA-7227
URL: https://issues.apache.org/jira/browse/KAFKA-7227
Project: Kafka
Issue Type: Impro
[
https://issues.apache.org/jira/browse/KAFKA-7216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Satish Duggana updated KAFKA-7216:
--
Component/s: admin
> Exception while running kafka-acls.sh from 1.0 env on target Kafka env wit
[
https://issues.apache.org/jira/browse/KAFKA-7227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Genmao Yu updated KAFKA-7227:
-
Description:
In current behavior, if partial of broker machines have "server.rack", we will
failed to c
[
https://issues.apache.org/jira/browse/KAFKA-7216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16565242#comment-16565242
]
Satish Duggana commented on KAFKA-7216:
---
[~ijuma] I set component as `admin` as `Ac
[
https://issues.apache.org/jira/browse/KAFKA-7227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Genmao Yu updated KAFKA-7227:
-
Description:
In current behavior, if partial of broker machines have "server.rack", we will
failed to c
[
https://issues.apache.org/jira/browse/KAFKA-7227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Genmao Yu updated KAFKA-7227:
-
Priority: Minor (was: Major)
> Kafka cluster should has a default rack id if not set
> -
[
https://issues.apache.org/jira/browse/KAFKA-5587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lambdaliu updated KAFKA-5587:
-
Affects Version/s: 0.10.2.1
> Processor got uncaught exception: NullPointerException
> --
[
https://issues.apache.org/jira/browse/KAFKA-7215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16565498#comment-16565498
]
ASF GitHub Bot commented on KAFKA-7215:
---
stanislavkozlovski opened a new pull reque
[
https://issues.apache.org/jira/browse/KAFKA-7228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arjun Satish reassigned KAFKA-7228:
---
Assignee: Arjun Satish
> DeadLetterQueue throws a NullPointerException
> ---
Arjun Satish created KAFKA-7228:
---
Summary: DeadLetterQueue throws a NullPointerException
Key: KAFKA-7228
URL: https://issues.apache.org/jira/browse/KAFKA-7228
Project: Kafka
Issue Type: Task
[
https://issues.apache.org/jira/browse/KAFKA-7228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arjun Satish updated KAFKA-7228:
Description:
Using the dead letter queue results in a NPE:
{code:java}
[2018-08-01 07:41:08,907]
[
https://issues.apache.org/jira/browse/KAFKA-7228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16565540#comment-16565540
]
ASF GitHub Bot commented on KAFKA-7228:
---
wicknicks opened a new pull request #5440:
Yu Yang created KAFKA-7229:
--
Summary: Failed to dynamically update kafka certificate in kafka
2.0.0
Key: KAFKA-7229
URL: https://issues.apache.org/jira/browse/KAFKA-7229
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-7229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Yang updated KAFKA-7229:
---
Description:
In kafka 1.1, we use the following command in a cron job to dynamically update
the certificate
[
https://issues.apache.org/jira/browse/KAFKA-7229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Yang updated KAFKA-7229:
---
Priority: Critical (was: Major)
> Failed to dynamically update kafka certificate in kafka 2.0.0
> --
[
https://issues.apache.org/jira/browse/KAFKA-7229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16565613#comment-16565613
]
Ismael Juma commented on KAFKA-7229:
Looks like you have to disable hostname verifica
[
https://issues.apache.org/jira/browse/KAFKA-7229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16565615#comment-16565615
]
Rajini Sivaram commented on KAFKA-7229:
---
In 2.0.0, we enable SSL host name verifica
[
https://issues.apache.org/jira/browse/KAFKA-7144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-7144:
-
Fix Version/s: 2.0.1
> Kafka Streams doesn't properly balance partition assignment
>
[
https://issues.apache.org/jira/browse/KAFKA-7229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16565625#comment-16565625
]
Manikumar commented on KAFKA-7229:
--
This may be due to the default value change for
"ss
[
https://issues.apache.org/jira/browse/KAFKA-7229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Yang resolved KAFKA-7229.
Resolution: Not A Problem
> Failed to dynamically update kafka certificate in kafka 2.0.0
> ---
[
https://issues.apache.org/jira/browse/KAFKA-7229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Manikumar updated KAFKA-7229:
-
Comment: was deleted
(was: This may be due to the default value change for
"ssl.endpoint.identification.
[
https://issues.apache.org/jira/browse/KAFKA-7229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Yang updated KAFKA-7229:
---
Priority: Major (was: Critical)
> Failed to dynamically update kafka certificate in kafka 2.0.0
> --
[
https://issues.apache.org/jira/browse/KAFKA-7219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16565641#comment-16565641
]
Sriharsha Chintalapani commented on KAFKA-7219:
---
[~satish.duggana] one more
Julien Fabre created KAFKA-7230:
---
Summary: Empty Record created when producer failed due to
RecordTooLargeException
Key: KAFKA-7230
URL: https://issues.apache.org/jira/browse/KAFKA-7230
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-7226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16565681#comment-16565681
]
Manikumar commented on KAFKA-7226:
--
looks like the issue is specific to HDP Kafka distri
[
https://issues.apache.org/jira/browse/KAFKA-7230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Julien Fabre updated KAFKA-7230:
Description:
When a producer tries to produce a RecordBatch which is bigger than the
message.max.b
[
https://issues.apache.org/jira/browse/KAFKA-7230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Julien Fabre updated KAFKA-7230:
Description:
When a producer tries to produce a RecordBatch which is bigger than the
message.max.b
[
https://issues.apache.org/jira/browse/KAFKA-7230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Julien Fabre updated KAFKA-7230:
Description:
When a producer tries to produce a RecordBatch which is bigger than the
message.max.b
[
https://issues.apache.org/jira/browse/KAFKA-7230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Julien Fabre updated KAFKA-7230:
Description:
When a producer tries to produce a RecordBatch (or Message) which is bigger
than the
[
https://issues.apache.org/jira/browse/KAFKA-7230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Julien Fabre updated KAFKA-7230:
Description:
When a producer tries to produce a RecordBatch which is bigger than the
message.max.b
[
https://issues.apache.org/jira/browse/KAFKA-7230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Julien Fabre updated KAFKA-7230:
Summary: Empty Record created when producer fails due to
RecordTooLargeException (was: Empty Recor
[
https://issues.apache.org/jira/browse/KAFKA-7219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16565692#comment-16565692
]
George Teo commented on KAFKA-7219:
---
Another slightly bigger ask would be to also emit
[
https://issues.apache.org/jira/browse/KAFKA-7226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16565681#comment-16565681
]
Manikumar edited comment on KAFKA-7226 at 8/1/18 5:37 PM:
--
looks
[
https://issues.apache.org/jira/browse/KAFKA-7161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-7161.
--
Resolution: Fixed
Fix Version/s: 2.1.0
> KTable Reduce should check for invalid conditio
[
https://issues.apache.org/jira/browse/KAFKA-7161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16565731#comment-16565731
]
ASF GitHub Bot commented on KAFKA-7161:
---
guozhangwang closed pull request #5366: KA
[
https://issues.apache.org/jira/browse/KAFKA-6868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16565753#comment-16565753
]
Sriharsha Chintalapani commented on KAFKA-6868:
---
[~hachikuji] can we includ
[
https://issues.apache.org/jira/browse/KAFKA-7209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16565772#comment-16565772
]
Matthias J. Sax commented on KAFKA-7209:
About `offsets.topic.replication.factor`
Ron Dagostino created KAFKA-7231:
Summary: NetworkClient.newClientRequest() ignores custom request
timeout in favor of the default
Key: KAFKA-7231
URL: https://issues.apache.org/jira/browse/KAFKA-7231
[
https://issues.apache.org/jira/browse/KAFKA-7231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ron Dagostino updated KAFKA-7231:
-
Description:
The below code in {{org.apache.kafka.clients.KafkaClient}} is not passing in
the pr
[
https://issues.apache.org/jira/browse/KAFKA-7228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arjun Satish updated KAFKA-7228:
Fix Version/s: 2.1.0
2.0.1
> DeadLetterQueue throws a NullPointerException
> ---
[
https://issues.apache.org/jira/browse/KAFKA-7231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson reassigned KAFKA-7231:
--
Assignee: Jason Gustafson
> NetworkClient.newClientRequest() ignores custom request ti
[
https://issues.apache.org/jira/browse/KAFKA-7231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16565964#comment-16565964
]
Jason Gustafson commented on KAFKA-7231:
Ouch. I think the only place we use this
[
https://issues.apache.org/jira/browse/KAFKA-4701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16566017#comment-16566017
]
ASF GitHub Bot commented on KAFKA-4701:
---
allenxiang closed pull request #2446: KAFK
[
https://issues.apache.org/jira/browse/KAFKA-7231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16566168#comment-16566168
]
ASF GitHub Bot commented on KAFKA-7231:
---
hachikuji opened a new pull request #5444:
[
https://issues.apache.org/jira/browse/KAFKA-7225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Yokota reassigned KAFKA-7225:
Assignee: Robert Yokota
> Kafka Connect ConfigProvider not invoked before validation
> ---
[
https://issues.apache.org/jira/browse/KAFKA-7175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16566241#comment-16566241
]
Ted Yu commented on KAFKA-7175:
---
What Ray said sounds feasible.
> Make version checking lo
[
https://issues.apache.org/jira/browse/KAFKA-7049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16566242#comment-16566242
]
Ted Yu commented on KAFKA-7049:
---
Haven't seen this error for a little while.
> InternalTop
[
https://issues.apache.org/jira/browse/KAFKA-6303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16333251#comment-16333251
]
Ted Yu edited comment on KAFKA-6303 at 8/2/18 1:48 AM:
---
+1 from me
[
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-7225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16566297#comment-16566297
]
ASF GitHub Bot commented on KAFKA-7225:
---
rayokota opened a new pull request #5445:
Ratish Ravindran created KAFKA-7232:
---
Summary: Allow kafka-topics.sh to take brokerid as parameter to
show partitions associated with it
Key: KAFKA-7232
URL: https://issues.apache.org/jira/browse/KAFKA-7232
Hashan Gayasri Udugahapattuwa created KAFKA-7233:
Summary: InMemoryKeyValueStore is not thread-safe for Interactive
Queries
Key: KAFKA-7233
URL: https://issues.apache.org/jira/browse/KAFKA-7233
Jason Gustafson created KAFKA-7234:
--
Summary: Allow auto leader rebalance during partition reassignment
Key: KAFKA-7234
URL: https://issues.apache.org/jira/browse/KAFKA-7234
Project: Kafka
I
[
https://issues.apache.org/jira/browse/KAFKA-7235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-7235:
Description:
Currently a broker can process controller requests that are sent before the
broker is restart
Dong Lin created KAFKA-7235:
---
Summary: Use brokerZkNodeVersion to prevent broker from processing
outdated controller request
Key: KAFKA-7235
URL: https://issues.apache.org/jira/browse/KAFKA-7235
Project: Ka
64 matches
Mail list logo