[
https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14711679#comment-14711679
]
Sriharsha Chintalapani commented on KAFKA-1690:
---
[~sourabh0612] SSL or any
On Aug. 22, 2015, 12:45 a.m., Joel Koshy wrote:
clients/src/main/java/org/apache/kafka/common/requests/FetchResponse.java,
line 107
https://reviews.apache.org/r/33378/diff/12-13/?file=1043780#file1043780line107
This will probably need a versionId as well (as is done in the Scala
I thought Gwen's suggestion was to us a separate folder in the same repo
for docs instead of a separate branch, Gwen can correct me if I was wrong?
Guozhang
On Mon, Aug 24, 2015 at 10:31 AM, Manikumar Reddy ku...@nmsworks.co.in
wrote:
Hi,
Infra team created git repo for kafka site docs.
[
https://issues.apache.org/jira/browse/KAFKA-1811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14711498#comment-14711498
]
ASF GitHub Bot commented on KAFKA-1811:
---
GitHub user eribeiro opened a pull request:
[
https://issues.apache.org/jira/browse/KAFKA-2122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gwen Shapira updated KAFKA-2122:
Fix Version/s: 0.8.3
Remove controller.message.queue.size Config
[
https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14711698#comment-14711698
]
Sourabh Chandak commented on KAFKA-1690:
[~sriharsha] Sorry it might be a noob
Manish Sharma created KAFKA-2471:
Summary: Replicas Order and Leader out of sync
Key: KAFKA-2471
URL: https://issues.apache.org/jira/browse/KAFKA-2471
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-1811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Edward Ribeiro updated KAFKA-1811:
--
Summary: Ensuring registered broker host:port is unique (was: ensuring
registered broker
[
https://issues.apache.org/jira/browse/KAFKA-2385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14711441#comment-14711441
]
João Reis commented on KAFKA-2385:
--
It seems to be a Zookeeper problem as stated here:
[
https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14711100#comment-14711100
]
Navjot edited comment on KAFKA-1690 at 8/25/15 2:15 PM:
[
https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14711376#comment-14711376
]
Rajasekar Elango commented on KAFKA-1690:
-
SSLv3 was disabled since jdk version
Sriharsha Chintalapani created KAFKA-2472:
-
Summary: Fix kafka ssl configs to not throw warnings
Key: KAFKA-2472
URL: https://issues.apache.org/jira/browse/KAFKA-2472
Project: Kafka
Hi Prabhjot,
There are two important things to know about kafka compression: First
uncompression happens automatically in the consumer
(https://cwiki.apache.org/confluence/display/KAFKA/Compression) so you
should see ascii returned on the consumer side. The best way to see if
compression has
Prabhjot,
When no compression is being used, it should have only a tiny impact on
performance. But when it is enabled it will make it as though the message
payload is small and nearly constant, regardless as to how large the configured
message size is.
I think that the answer is that this is
[
https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14711565#comment-14711565
]
Sriharsha Chintalapani commented on KAFKA-1690:
---
[~NavjotBhardwaj] it
[
https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14711624#comment-14711624
]
Sourabh Chandak commented on KAFKA-1690:
[~sriharsha] Is the simple consumer also
[
https://issues.apache.org/jira/browse/KAFKA-2468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14712397#comment-14712397
]
Ewen Cheslack-Postava commented on KAFKA-2468:
--
[~ashi.khur...@gmail.com] Ok,
Hi,
Turns out to be a bug in the instructions in the wiki . I fixed it can
you please retry generating the truststore and keystore
https://cwiki.apache.org/confluence/display/KAFKA/Deploying+SSL+for+Kafka .
checkout this section All of the above steps in a bash script” to generate the
Ewen Cheslack-Postava created KAFKA-2475:
Summary: Reduce copycat configs to only specify a converter or
serializer, not both
Key: KAFKA-2475
URL: https://issues.apache.org/jira/browse/KAFKA-2475
Ewen Cheslack-Postava created KAFKA-2476:
Summary: Define logical types for Copycat data API
Key: KAFKA-2476
URL: https://issues.apache.org/jira/browse/KAFKA-2476
Project: Kafka
Hi Xiang,
Did you try following the instructions here
https://cwiki.apache.org/confluence/display/KAFKA/Deploying+SSL+for+Kafka .
Whats the output of openssl s_client and which version of java and OS are you
using.
Thanks,
Harsha
On August 25, 2015 at 8:42:18 PM, Xiang Zhou (Samuel)
Ewen Cheslack-Postava created KAFKA-2474:
Summary: Add caching for converted Copycat schemas in JSONConverter
Key: KAFKA-2474
URL: https://issues.apache.org/jira/browse/KAFKA-2474
Project:
[
https://issues.apache.org/jira/browse/KAFKA-2367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14712401#comment-14712401
]
Gwen Shapira commented on KAFKA-2367:
-
My opinions / comments on the above:
* Logical
[
https://issues.apache.org/jira/browse/KAFKA-2468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14712413#comment-14712413
]
Ashish K Singh commented on KAFKA-2468:
---
[~guozhang] could you review and help with
[
https://issues.apache.org/jira/browse/KAFKA-2367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14712472#comment-14712472
]
Jay Kreps commented on KAFKA-2367:
--
On unions: they were kind of a disaster at LinkedIn.
GitHub user SinghAsDev opened a pull request:
https://github.com/apache/kafka/pull/167
KAFKA-2468: SIGINT during Kafka server startup can leave server deadlocked
As we handle exceptions or invalid states in Kafka server by shutting it
down, there is no reason to use exit() and not
[
https://issues.apache.org/jira/browse/KAFKA-2466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14710804#comment-14710804
]
Ashish K Singh commented on KAFKA-2466:
---
OK, thanks for taking care of it.
[
https://issues.apache.org/jira/browse/KAFKA-2467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14710829#comment-14710829
]
Ewen Cheslack-Postava commented on KAFKA-2467:
--
[~ijuma] Sort of. We still
[
https://issues.apache.org/jira/browse/KAFKA-2467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14710836#comment-14710836
]
Ismael Juma commented on KAFKA-2467:
Thanks for the explanation [~ewencp]. That sounds
[
https://issues.apache.org/jira/browse/KAFKA-2467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14710860#comment-14710860
]
Ben Stopford commented on KAFKA-2467:
-
Apologies for this regression. 2015 was adapted
Ewen Cheslack-Postava created KAFKA-2469:
Summary: System test console consumer logs should write all
messages to debug logger
Key: KAFKA-2469
URL: https://issues.apache.org/jira/browse/KAFKA-2469
[
https://issues.apache.org/jira/browse/KAFKA-2468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14710800#comment-14710800
]
ASF GitHub Bot commented on KAFKA-2468:
---
GitHub user SinghAsDev opened a pull
Github user thinker0 closed the pull request at:
https://github.com/apache/kafka/pull/31
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
[
https://issues.apache.org/jira/browse/KAFKA-1369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14710907#comment-14710907
]
ASF GitHub Bot commented on KAFKA-1369:
---
Github user thinker0 closed the pull
[
https://issues.apache.org/jira/browse/KAFKA-2377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14710668#comment-14710668
]
Ewen Cheslack-Postava commented on KAFKA-2377:
--
By the way, might be worth
[
https://issues.apache.org/jira/browse/KAFKA-2467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14710825#comment-14710825
]
Ismael Juma commented on KAFKA-2467:
[~ewencp], do I understand correctly that the
[
https://issues.apache.org/jira/browse/KAFKA-2466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14710732#comment-14710732
]
Ewen Cheslack-Postava commented on KAFKA-2466:
--
This isn't a behavior
Ashish K Singh created KAFKA-2468:
-
Summary: SIGINT during Kafka server startup can leave server
deadlocked
Key: KAFKA-2468
URL: https://issues.apache.org/jira/browse/KAFKA-2468
Project: Kafka
Hi Erik,
Thanks for these inputs
I'll implement it
Regards,
Prabhjot
On Aug 25, 2015 11:53 PM, Helleren, Erik erik.helle...@cmegroup.com
wrote:
Prabhjot,
You can’t do it with producer perf test, but its relatively simple to
implement. The message body includes a timestamp of when your
[
https://issues.apache.org/jira/browse/KAFKA-2367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gwen Shapira updated KAFKA-2367:
Status: Patch Available (was: Open)
Add Copycat runtime data API
[
https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14711715#comment-14711715
]
Navjot commented on KAFKA-1690:
---
Yes [~harsha_ch] I deployed it on windows without SSL and
[
https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14711718#comment-14711718
]
Navjot commented on KAFKA-1690:
---
Yes [~harsha_ch] I deployed it on windows without SSL and
[
https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14711717#comment-14711717
]
Navjot commented on KAFKA-1690:
---
Yes [~harsha_ch] I deployed it on windows without SSL and
[
https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14711719#comment-14711719
]
Navjot commented on KAFKA-1690:
---
Yes [~harsha_ch] I deployed it on windows without SSL and
[
https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14711720#comment-14711720
]
Navjot commented on KAFKA-1690:
---
Yes [~harsha_ch] I deployed it on windows without SSL and
[
https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navjot updated KAFKA-1690:
--
Comment: was deleted
(was: Yes [~harsha_ch] I deployed it on windows without SSL and it was running
absolutely
[
https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navjot updated KAFKA-1690:
--
Comment: was deleted
(was: Yes [~harsha_ch] I deployed it on windows without SSL and it was running
absolutely
[
https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navjot updated KAFKA-1690:
--
Comment: was deleted
(was: Yes [~harsha_ch] I deployed it on windows without SSL and it was running
absolutely
[
https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navjot updated KAFKA-1690:
--
Comment: was deleted
(was: Yes [~harsha_ch] I deployed it on windows without SSL and it was running
absolutely
[
https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navjot updated KAFKA-1690:
--
Comment: was deleted
(was: Yes [~harsha_ch] I deployed it on windows without SSL and it was running
absolutely
[
https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14711741#comment-14711741
]
Navjot commented on KAFKA-1690:
---
Yes [~harsha_ch] I deployed it on windows and
[
https://issues.apache.org/jira/browse/KAFKA-2136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14711745#comment-14711745
]
Aditya A Auradkar commented on KAFKA-2136:
--
Updated reviewboard
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/33378/
---
(Updated Aug. 25, 2015, 6:30 p.m.)
Review request for kafka, Joel Koshy and
Prabhjot,
You can’t do it with producer perf test, but its relatively simple to
implement. The message body includes a timestamp of when your producer
produces, and the consumer looks at the difference between between the
timestamp in the body and the current timestamp.
Or, if you were looking
[
https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14711733#comment-14711733
]
Ismael Juma commented on KAFKA-1690:
[~sourabh0612], it would be better to take this
[
https://issues.apache.org/jira/browse/KAFKA-2136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aditya A Auradkar updated KAFKA-2136:
-
Attachment: KAFKA-2136_2015-08-25_11:29:52.patch
Client side protocol changes to return
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/33378/
---
(Updated Aug. 25, 2015, 6:30 p.m.)
Review request for kafka, Joel Koshy and
GitHub user SinghAsDev opened a pull request:
https://github.com/apache/kafka/pull/169
KAFKA-2461: request logger no longer logs extra information in debug mode
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/SinghAsDev/kafka
[
https://issues.apache.org/jira/browse/KAFKA-2461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14712096#comment-14712096
]
ASF GitHub Bot commented on KAFKA-2461:
---
GitHub user SinghAsDev opened a pull
[
https://issues.apache.org/jira/browse/KAFKA-2473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Amar updated KAFKA-2473:
Summary: Not able to find release version with patch jira-1591 (was: Not
able to release version with patch
Amar created KAFKA-2473:
---
Summary: Not able to release version with patch jira-1591
Key: KAFKA-2473
URL: https://issues.apache.org/jira/browse/KAFKA-2473
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-2385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14711084#comment-14711084
]
João Reis commented on KAFKA-2385:
--
Hi guys,
Maybe is not related with this issue, but
[
https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14711100#comment-14711100
]
Navjot edited comment on KAFKA-1690 at 8/25/15 11:32 AM:
-
[
https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14711100#comment-14711100
]
Navjot commented on KAFKA-1690:
---
@Sriharsha Please find the java version below:
{{java
Hi,
I have bene trying to use kafka-producer-perf-test.sh to arrive at certain
benchmarks.
When I try to run it with --compression-codec values of 1, 2 and 3, I
notice increased throughput compared to NoCompressionCodec
But, When I checked the Producerperformance.scala, I saw that the the
Bo Wang created KAFKA-2470:
--
Summary: kafka-producer-perf-test.sh can't configure all to
request-num-acks
Key: KAFKA-2470
URL: https://issues.apache.org/jira/browse/KAFKA-2470
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-1387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14711838#comment-14711838
]
Guozhang Wang commented on KAFKA-1387:
--
Thanks [~fpj], thanks for the patch. Here are
[
https://issues.apache.org/jira/browse/KAFKA-2468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14712225#comment-14712225
]
Ashish K Singh edited comment on KAFKA-2468 at 8/26/15 12:13 AM:
[
https://issues.apache.org/jira/browse/KAFKA-2468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14712225#comment-14712225
]
Ashish K Singh commented on KAFKA-2468:
---
[~ewencp] unlike exit(), halt() forcibly
[
https://issues.apache.org/jira/browse/KAFKA-2388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14712236#comment-14712236
]
Jason Gustafson commented on KAFKA-2388:
[~onurkaraman] I've updated the patch to
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/36652/#review96463
---
Ship it!
Ship It!
- Joel Koshy
On Aug. 24, 2015, 10:50 p.m.,
[
https://issues.apache.org/jira/browse/KAFKA-2351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy updated KAFKA-2351:
--
Resolution: Fixed
Status: Resolved (was: Patch Available)
Committed to trunk.
Brokers are
[
https://issues.apache.org/jira/browse/KAFKA-2473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Amar resolved KAFKA-2473.
-
Resolution: Not A Problem
Not able to find release version with patch jira-1591
[
https://issues.apache.org/jira/browse/KAFKA-2468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14712201#comment-14712201
]
Ewen Cheslack-Postava commented on KAFKA-2468:
--
Does this actually solve the
[
https://issues.apache.org/jira/browse/KAFKA-2461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gwen Shapira updated KAFKA-2461:
Fix Version/s: 0.8.3
request logger no longer logs extra information in debug mode
[
https://issues.apache.org/jira/browse/KAFKA-2473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14712009#comment-14712009
]
Edward Ribeiro edited comment on KAFKA-2473 at 8/25/15 9:30 PM:
Hi Erik,
I have put my efforts on the produce side till now, Thanks for making me
aware that consumer will decompress automatically.
I'll also consider your point on creating real-life messages
But, I have still have one confusion -
Why would the current ProducerPerformance.scala compress an
On Aug. 23, 2015, 9:29 p.m., Jun Rao wrote:
core/src/main/scala/kafka/security/auth/KafkaPrincipal.scala, line 21
https://reviews.apache.org/r/34492/diff/11/?file=1045205#file1045205line21
There is a java version of KafkaPrincipal. Could we consolidate?
consolidated. Converted
[
https://issues.apache.org/jira/browse/KAFKA-2210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14712282#comment-14712282
]
Parth Brahmbhatt commented on KAFKA-2210:
-
Updated reviewboard
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/34492/
---
(Updated Aug. 26, 2015, 12:59 a.m.)
Review request for kafka.
Bugs:
[
https://issues.apache.org/jira/browse/KAFKA-2210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Parth Brahmbhatt updated KAFKA-2210:
Attachment: KAFKA-2210_2015-08-25_17:59:22.patch
KafkaAuthorizer: Add all public entities,
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/33378/#review96470
---
Ship it!
Ship It!
- Joel Koshy
On Aug. 25, 2015, 6:30 p.m.,
See https://builds.apache.org/job/Kafka-trunk/598/changes
[
https://issues.apache.org/jira/browse/KAFKA-2145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14712319#comment-14712319
]
Parth Brahmbhatt commented on KAFKA-2145:
-
[~junrao] Pinging again for review.
[
https://issues.apache.org/jira/browse/KAFKA-2136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14712324#comment-14712324
]
Joel Koshy commented on KAFKA-2136:
---
Thanks for the patches - pushed to trunk. Can you
[
https://issues.apache.org/jira/browse/KAFKA-2388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14712347#comment-14712347
]
Onur Karaman commented on KAFKA-2388:
-
Sounds okay to me. I'll try to take a look at
On Aug. 21, 2015, 12:13 a.m., Joel Koshy wrote:
core/src/main/scala/kafka/api/FetchResponse.scala, line 175
https://reviews.apache.org/r/33378/diff/12/?file=1043787#file1043787line175
Since (in the event of multiple calls) this grouping would be repeated,
should we just have
87 matches
Mail list logo
