I agree with that statement that if producer is closed and try to send
message it will give close. What we have done is wrap the NEW Producer API
with Old Producer API. So when I use same code with OLD I do not get this
issue. It is only problem with NEW Producer. Regardless of close, state I
[
https://issues.apache.org/jira/browse/KAFKA-1644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Anton Karamanov updated KAFKA-1644:
---
Attachment: 0003-KAFKA-1644-Inherit-FetchResponse-from-RequestOrRespo.patch
Indeed. Here's
Hello There,
I have the following in my server.properties on a two node kafka test
cluster
….
port=6667
host.name=f-bcpc-vm3.bcpc.example.com
advertised.host.name=f-bcpc-vm3.bcpc.example.com
advertised.port=9092
…
When I bring up Kafka, there is no process listening on port 9092 but Kafka
[
https://issues.apache.org/jira/browse/KAFKA-1646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14161857#comment-14161857
]
xueqiang wang commented on KAFKA-1646:
--
This issue is caused by the discrete blocks
[
https://issues.apache.org/jira/browse/KAFKA-1663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Narkhede reopened KAFKA-1663:
--
[~sriharsha], while talking to Jun, realized that there may have been a
regression introduced by
[
https://issues.apache.org/jira/browse/KAFKA-1663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14161942#comment-14161942
]
Sriharsha Chintalapani commented on KAFKA-1663:
---
[~nehanarkhede] Both
Sriharsha Chintalapani created KAFKA-1681:
-
Summary: Newly elected KafkaController might not start deletion of
pending topics
Key: KAFKA-1681
URL: https://issues.apache.org/jira/browse/KAFKA-1681
Hi Kafka Dev Team,
Since we have multiple instance of producers within one JVM, it would be
good idea to name network IO thread name by associate with client.id
configuration.
kafka-producer-network-thread + client.tId
Thanks,
Bhavesh
KAFKA-1092 (https://issues.apache.org/jira/browse/KAFKA-1092) provided the
answer to the query. Thanks all.
On Tue, Oct 7, 2014 at 8:26 AM, Biju N bijuatapa...@gmail.com wrote:
Hello There,
I have the following in my server.properties on a two node kafka test
cluster
….
port=6667
[
https://issues.apache.org/jira/browse/KAFKA-1681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Narkhede updated KAFKA-1681:
-
Fix Version/s: 0.8.2
Newly elected KafkaController might not start deletion of pending topics
[
https://issues.apache.org/jira/browse/KAFKA-1646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14162106#comment-14162106
]
Jay Kreps commented on KAFKA-1646:
--
Ah, you are saying Windows does a worse job of
Hey Bhavesh,
But isn't the problem here that you are trying to send messages after
closing the producer?
I think what I am saying is that since calling close is something the user
initiates we don't need an api for this--you can keep track of this
yourself, right?
-Jay
On Mon, Oct 6, 2014 at
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/25995/#review55612
---
[
https://issues.apache.org/jira/browse/KAFKA-1646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14162106#comment-14162106
]
Jay Kreps edited comment on KAFKA-1646 at 10/7/14 6:23 PM:
---
Ah,
[
https://issues.apache.org/jira/browse/KAFKA-1499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14162336#comment-14162336
]
Joel Koshy commented on KAFKA-1499:
---
Talked to Jay offline and here is a summary of what
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/26390/#review55696
---
core/src/main/scala/kafka/log/LogCleanerManager.scala
[
https://issues.apache.org/jira/browse/KAFKA-1670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sriharsha Chintalapani updated KAFKA-1670:
--
Attachment: KAFKA-1670_2014-10-07_13:39:13.patch
Corrupt log files for
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/26346/
---
(Updated Oct. 7, 2014, 8:39 p.m.)
Review request for kafka.
Bugs: KAFKA-1670
[
https://issues.apache.org/jira/browse/KAFKA-1670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14162486#comment-14162486
]
Sriharsha Chintalapani commented on KAFKA-1670:
---
Updated reviewboard
On Oct. 7, 2014, 12:42 a.m., Jay Kreps wrote:
core/src/main/scala/kafka/log/Log.scala, line 502
https://reviews.apache.org/r/26346/diff/3/?file=714142#file714142line502
It is a bit subtle that you are checking for overflow this way. What we
mean to check is just that there is
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/26346/
---
(Updated Oct. 7, 2014, 8:49 p.m.)
Review request for kafka.
Bugs: KAFKA-1670
[
https://issues.apache.org/jira/browse/KAFKA-1670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14162507#comment-14162507
]
Sriharsha Chintalapani commented on KAFKA-1670:
---
Updated reviewboard
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/26291/#review55702
---
core/src/main/scala/kafka/consumer/PartitionAssignor.scala
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/26346/#review55720
---
On Oct. 7, 2014, 11:03 p.m., Jun Rao wrote:
core/src/main/scala/kafka/common/MessageSetSizeTooLargeException.scala,
line 20
https://reviews.apache.org/r/26346/diff/5/?file=714846#file714846line20
We need to add this exception to ErrorMapping and Errors. We also need
to add
Jay Kreps created KAFKA-1682:
Summary: Security for Kafka
Key: KAFKA-1682
URL: https://issues.apache.org/jira/browse/KAFKA-1682
Project: Kafka
Issue Type: New Feature
Affects Versions: 0.9.0
[
https://issues.apache.org/jira/browse/KAFKA-1682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-1682:
-
Description:
Parent ticket for security. Wiki and discussion is here:
Jay Kreps created KAFKA-1683:
Summary: Implement a session concept in the socket server
Key: KAFKA-1683
URL: https://issues.apache.org/jira/browse/KAFKA-1683
Project: Kafka
Issue Type: Sub-task
Jay Kreps created KAFKA-1684:
Summary: Implement SSL authentication
Key: KAFKA-1684
URL: https://issues.apache.org/jira/browse/KAFKA-1684
Project: Kafka
Issue Type: Sub-task
Affects
[
https://issues.apache.org/jira/browse/KAFKA-1684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-1684:
-
Summary: Implement TLS/SSL authentication (was: Implement SSL
authentication)
Implement TLS/SSL
Jay Kreps created KAFKA-1685:
Summary: Implement TLS/SSL tests
Key: KAFKA-1685
URL: https://issues.apache.org/jira/browse/KAFKA-1685
Project: Kafka
Issue Type: Sub-task
Affects Versions:
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/25886/#review55730
---
Looks good. Just some minor comments below.
Jay Kreps created KAFKA-1686:
Summary: Implement SASL/Kerberos
Key: KAFKA-1686
URL: https://issues.apache.org/jira/browse/KAFKA-1686
Project: Kafka
Issue Type: Sub-task
Affects Versions:
Jay Kreps created KAFKA-1687:
Summary: SASL tests
Key: KAFKA-1687
URL: https://issues.apache.org/jira/browse/KAFKA-1687
Project: Kafka
Issue Type: Sub-task
Reporter: Jay Kreps
We
[
https://issues.apache.org/jira/browse/KAFKA-1555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14162833#comment-14162833
]
Jun Rao commented on KAFKA-1555:
The patch that Gwen provided (using a min.isr topic level
We are going to deploy Kafka in Production and also monitor it via console.
(e.g. State of partitions in Broker- leader and slaves, state of consumers )
Is there out-of-the-box solution?
What is the best and efficient way of deployment and monitoring
Has someone tried this- looks promising
Jay Kreps created KAFKA-1688:
Summary: Add authorization interface and naive implementation
Key: KAFKA-1688
URL: https://issues.apache.org/jira/browse/KAFKA-1688
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-1684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14162839#comment-14162839
]
Jay Kreps commented on KAFKA-1684:
--
We may be able to get most of the implementation for
Hey guys,
As promised, I added a tree of JIRAs for the stuff in the security wiki (
https://cwiki.apache.org/confluence/display/KAFKA/Security):
https://issues.apache.org/jira/browse/KAFKA-1682
I tried to break it into reasonably standalone pieces. I think many of the
tickets could actually be
On Oct. 7, 2014, 11:03 p.m., Jun Rao wrote:
core/src/test/scala/unit/kafka/log/LogTest.scala, line 242
https://reviews.apache.org/r/26346/diff/5/?file=714849#file714849line242
By increasing the segment size to 100, does the log still roll on every
message as indicated by the
I think we need to add:
* Authentication of Kafka brokers with a secured ZooKeeper
* Kafka should be able to generate delegation tokens for MapReduce /
Spark / Yarn jobs.
* Extend systest framework to allow testing secured kafka
Gwen
On Tue, Oct 7, 2014 at 5:15 PM, Jay Kreps jay.kr...@gmail.com
I'm using Hue's ZooKeeper app: http://gethue.com/new-zookeeper-browser-app/
This UI looks very cute, but I didn't try it yet:
https://github.com/claudemamo/kafka-web-console
Gwen
On Tue, Oct 7, 2014 at 5:08 PM, Shafaq s.abdullah...@gmail.com wrote:
We are going to deploy Kafka in Production
We use http://quantifind.com/KafkaOffsetMonitor/...
On Tue, Oct 7, 2014 at 8:49 PM, Gwen Shapira gshap...@cloudera.com wrote:
I'm using Hue's ZooKeeper app:
http://gethue.com/new-zookeeper-browser-app/
This UI looks very cute, but I didn't try it yet:
On Oct. 7, 2014, 11:03 p.m., Jun Rao wrote:
core/src/test/scala/unit/kafka/log/LogTest.scala, line 242
https://reviews.apache.org/r/26346/diff/5/?file=714849#file714849line242
By increasing the segment size to 100, does the log still roll on every
message as indicated by the
[
https://issues.apache.org/jira/browse/KAFKA-1644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao updated KAFKA-1644:
---
Resolution: Fixed
Fix Version/s: 0.8.3
Status: Resolved (was: Patch Available)
That for
On Oct. 7, 2014, 11:03 p.m., Jun Rao wrote:
core/src/test/scala/unit/kafka/log/LogTest.scala, line 242
https://reviews.apache.org/r/26346/diff/5/?file=714849#file714849line242
By increasing the segment size to 100, does the log still roll on every
message as indicated by the
[
https://issues.apache.org/jira/browse/KAFKA-1670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sriharsha Chintalapani updated KAFKA-1670:
--
Attachment: KAFKA-1670_2014-10-07_18:39:31.patch
Corrupt log files for
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/26346/
---
(Updated Oct. 8, 2014, 1:39 a.m.)
Review request for kafka.
Bugs: KAFKA-1670
[
https://issues.apache.org/jira/browse/KAFKA-1670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14162918#comment-14162918
]
Sriharsha Chintalapani commented on KAFKA-1670:
---
Updated reviewboard
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/25886/
---
(Updated Oct. 8, 2014, 1:46 a.m.)
Review request for kafka.
Changes
---
On Oct. 8, 2014, midnight, Jun Rao wrote:
core/src/main/scala/kafka/cluster/Partition.scala, line 287
https://reviews.apache.org/r/25886/diff/8/?file=714240#file714240line287
The error code should be NotEnoughReplicasAfterAppendCode.
Good catch.
- Gwen
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/25886/#review55745
---
[
https://issues.apache.org/jira/browse/KAFKA-1555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14162942#comment-14162942
]
Joel Koshy commented on KAFKA-1555:
---
+1 (took a quick look at it)
We could improve the
[
https://issues.apache.org/jira/browse/KAFKA-1646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14162987#comment-14162987
]
xueqiang wang commented on KAFKA-1646:
--
Yes, if there are many deleting and creating,
54 matches
Mail list logo
