[
https://issues.apache.org/jira/browse/KAFKA-1387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14085792#comment-14085792
]
Joe Stein commented on KAFKA-1387:
--
Here is another way to reproduce this issue. I have
[
https://issues.apache.org/jira/browse/KAFKA-1387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14085792#comment-14085792
]
Joe Stein edited comment on KAFKA-1387 at 8/5/14 4:41 AM:
--
Here
[
https://issues.apache.org/jira/browse/KAFKA-1070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14085808#comment-14085808
]
Joe Stein edited comment on KAFKA-1070 at 8/5/14 5:06 AM
[
https://issues.apache.org/jira/browse/KAFKA-1070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14085808#comment-14085808
]
Joe Stein edited comment on KAFKA-1070 at 8/5/14 5:08 AM
[
https://issues.apache.org/jira/browse/KAFKA-1477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14080174#comment-14080174
]
Joe Stein commented on KAFKA-1477:
--
[~jkreps] agreed, next week sounds good
add
[
https://issues.apache.org/jira/browse/KAFKA-1555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14080210#comment-14080210
]
Joe Stein commented on KAFKA-1555:
--
+1 to introduce a new semantic when ack = -2
[
https://issues.apache.org/jira/browse/KAFKA-1477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14080355#comment-14080355
]
Joe Stein commented on KAFKA-1477:
--
Hey [~gwenshap] take a look where we are so far
[
https://issues.apache.org/jira/browse/KAFKA-1477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14077832#comment-14077832
]
Joe Stein edited comment on KAFKA-1477 at 7/29/14 7:50 PM:
---
Hi
[
https://issues.apache.org/jira/browse/KAFKA-1559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14075800#comment-14075800
]
Joe Stein commented on KAFKA-1559:
--
KAFKA-1490 should be taken care of before the next
[
https://issues.apache.org/jira/browse/KAFKA-1555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14074122#comment-14074122
]
Joe Stein commented on KAFKA-1555:
--
The simplification and guarantee provided with ack=-1
[
https://issues.apache.org/jira/browse/KAFKA-1555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14074122#comment-14074122
]
Joe Stein edited comment on KAFKA-1555 at 7/25/14 6:11 AM
[
https://issues.apache.org/jira/browse/KAFKA-1477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14074513#comment-14074513
]
Joe Stein commented on KAFKA-1477:
--
[~junrao] While I think it make sense to not try
[
https://issues.apache.org/jira/browse/KAFKA-1399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14073661#comment-14073661
]
Joe Stein commented on KAFKA-1399:
--
+1 to drop scala 2.8 support, lets do
[
https://issues.apache.org/jira/browse/KAFKA-1419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14073666#comment-14073666
]
Joe Stein commented on KAFKA-1419:
--
Thanks [~joecrobak] for the feedback/review. Yes, we
[
https://issues.apache.org/jira/browse/KAFKA-1419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14073666#comment-14073666
]
Joe Stein edited comment on KAFKA-1419 at 7/24/14 9:15 PM
[
https://issues.apache.org/jira/browse/KAFKA-1539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-1539:
-
Fix Version/s: 0.8.2
Due to OS caching Kafka might loose offset files which causes full reset of
data
[
https://issues.apache.org/jira/browse/KAFKA-1535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-1535:
-
Affects Version/s: (was: 0.8.2)
0.8.1.1
Fix Version/s: 0.8.2
return
[
https://issues.apache.org/jira/browse/KAFKA-1519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-1519:
-
Fix Version/s: 0.8.2
Console consumer: expose configuration option to enable/disable writing the
line
[
https://issues.apache.org/jira/browse/KAFKA-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-1512:
-
Fix Version/s: 0.8.2
Limit the maximum number of connections per ip address
[
https://issues.apache.org/jira/browse/KAFKA-1298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-1298:
-
Fix Version/s: 0.8.2
Controlled shutdown tool doesn't seem to work out of the box
[
https://issues.apache.org/jira/browse/KAFKA-1491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-1491:
-
Fix Version/s: 0.8.2
ConsumerMetadataResponse is not read completely
[
https://issues.apache.org/jira/browse/KAFKA-1316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-1316:
-
Fix Version/s: 0.8.2
Refactor Sender
---
Key: KAFKA-1316
[
https://issues.apache.org/jira/browse/KAFKA-1443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-1443:
-
Fix Version/s: 0.8.2
Add delete topic to topic commands and update DeleteTopicCommand
[
https://issues.apache.org/jira/browse/KAFKA-1469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-1469:
-
Fix Version/s: 0.8.2
Util.abs function does not return correct absolute values for negative values
[
https://issues.apache.org/jira/browse/KAFKA-1300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-1300:
-
Fix Version/s: (was: 0.8.1)
0.8.2
Added WaitForReplaction admin tool
[
https://issues.apache.org/jira/browse/KAFKA-1444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-1444:
-
Fix Version/s: 0.8.2
kafka.javaapi.TopicMetadata and PartitionMetadata doesn't forward the
toString
[
https://issues.apache.org/jira/browse/KAFKA-1238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-1238:
-
Fix Version/s: 0.8.2
New producer hangs in a loop detecting metadata for auto created topics
[
https://issues.apache.org/jira/browse/KAFKA-1328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-1328:
-
Fix Version/s: 0.8.2
Add new consumer APIs
-
Key: KAFKA-1328
[
https://issues.apache.org/jira/browse/KAFKA-1431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-1431:
-
Fix Version/s: 0.8.2
ConsoleConsumer - Option to clean zk consumer path
[
https://issues.apache.org/jira/browse/KAFKA-1425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-1425:
-
Fix Version/s: 0.8.2
provide logStartOffset in addition to LogEndOffset metric
[
https://issues.apache.org/jira/browse/KAFKA-1189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-1189:
-
Fix Version/s: 0.8.2
kafka-server-stop.sh doesn't stop broker
[
https://issues.apache.org/jira/browse/KAFKA-1414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-1414:
-
Fix Version/s: 0.8.2
Speedup broker startup after hard reset
[
https://issues.apache.org/jira/browse/KAFKA-1419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein reassigned KAFKA-1419:
Assignee: Ivan Lyutov
cross build for scala 2.11
[
https://issues.apache.org/jira/browse/KAFKA-1180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein reassigned KAFKA-1180:
Assignee: Joe Stein (was: Joel Koshy)
WhiteList topic filter gets a NullPointerException
[
https://issues.apache.org/jira/browse/KAFKA-1180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-1180:
-
Resolution: Fixed
Status: Resolved (was: Patch Available)
committed to trunk
WhiteList topic
Hi Pramod,
Can you increase KAFKA_HEAP_OPTS to lets say -Xmx1G in the
kafka-console-producer.sh to see if that gets you further along please in
your testing?
Thanks!
/***
Joe Stein
Founder, Principal Consultant
Big Data Open Source Security LLC
http
Shouldn't we make sure that the people in the contributor group have signed
and sent in their ICLA http://www.apache.org/licenses/icla.txt much like we
do for confluence? This helps to control also that all contributors have
signed an ICLA too.
/***
Joe
the person in the
asf-cla group... so we could just have our own contributor group and manage
that in confluence however we wanted?
/***
Joe Stein
Founder, Principal Consultant
Big Data Open Source Security LLC
http://www.stealth.ly
Twitter
I have been assigning people on confluence (they granted us access at that
time after some back and forth) we already have permission to-do that no
reason to talk to INFRA.
Everyone in the PMC should have access.
/***
Joe Stein
Founder, Principal
[
https://issues.apache.org/jira/browse/KAFKA-1180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14063745#comment-14063745
]
Joe Stein commented on KAFKA-1180:
--
if you could please that would be great, sorry I am
is with 2.8.0 and want to stick to it.
Thanks,
Pramod
On Tue, Jun 3, 2014 at 3:57 PM, Joe Stein joe.st...@stealth.ly wrote:
Hi,I wanted to re-ignite the discussion around Apache Kafka Security.
This
is a huge bottleneck (non-starter in some cases) for a lot of
organizations
(due to regulatory
Here are the newbie labels in JIRA for open Kafka tickets
https://issues.apache.org/jira/issues/?jql=project%20%3D%20KAFKA%20AND%20labels%20%3D%20newbie%20AND%20status%20%3D%20Open
/***
Joe Stein
Founder, Principal Consultant
Big Data Open Source
[
https://issues.apache.org/jira/browse/KAFKA-1180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14063745#comment-14063745
]
Joe Stein edited comment on KAFKA-1180 at 7/17/14 2:06 AM:
---
Yes
[
https://issues.apache.org/jira/browse/KAFKA-1180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14063745#comment-14063745
]
Joe Stein edited comment on KAFKA-1180 at 7/17/14 2:09 AM:
---
Yes
[
https://issues.apache.org/jira/browse/KAFKA-1174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein resolved KAFKA-1174.
--
Resolution: Won't Fix
this was resolved in the 0.8.1 build release , was a build issue
Empty jar
[
https://issues.apache.org/jira/browse/KAFKA-1454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein resolved KAFKA-1454.
--
Resolution: Won't Fix
Scala 2.11 works with 2.10 binaries http://www.scala-lang.org/news/2.11.0
[
https://issues.apache.org/jira/browse/KAFKA-1419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14049197#comment-14049197
]
Joe Stein commented on KAFKA-1419:
--
Is there a reason we need to-do this?
Scala 2.11
[
https://issues.apache.org/jira/browse/KAFKA-1419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14049210#comment-14049210
]
Joe Stein commented on KAFKA-1419:
--
That makes sense Scott (thanks) if you or someone
[
https://issues.apache.org/jira/browse/KAFKA-1419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-1419:
-
Priority: Blocker (was: Major)
Fix Version/s: 0.8.2
cross build for scala 2.11
[
https://issues.apache.org/jira/browse/KAFKA-1419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14049213#comment-14049213
]
Joe Stein commented on KAFKA-1419:
--
We might also be able to build and release
[
https://issues.apache.org/jira/browse/KAFKA-1454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14049214#comment-14049214
]
Joe Stein commented on KAFKA-1454:
--
discussion moved to KAFKA-1419 will take this up
) and
figured it was about time to-do this.
I am starting to look for more folks to talk about Kafka (running kafka,
eco system, clients, et el) so we can get some meetups scheduled and keep
things moving along (also venues).
Thanks!
/***
Joe Stein
Founder
Awesome Claude, thanks!
/***
Joe Stein
Founder, Principal Consultant
Big Data Open Source Security LLC
http://www.stealth.ly
Twitter: @allthingshadoop http://www.twitter.com/allthingshadoop
/
On Tue, Jun 24
[
https://issues.apache.org/jira/browse/KAFKA-1308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14042744#comment-14042744
]
Joe Stein commented on KAFKA-1308:
--
I am +1 to Jakob's suggestion and I can do
[
https://issues.apache.org/jira/browse/KAFKA-1308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14042749#comment-14042749
]
Joe Stein commented on KAFKA-1308:
--
which patch(s) would apply to the 0.8.1.1 tag
[
https://issues.apache.org/jira/browse/KAFKA-1308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14042804#comment-14042804
]
Joe Stein commented on KAFKA-1308:
--
Sounds good, I will wait for the commit to the 0.8.1
the consumer and elastic search do together I know there are lots of folks
from that eco system on this list so I hope they give it a whirl.
Thanks
/***
Joe Stein
Founder, Principal Consultant
Big Data Open Source Security LLC
http://www.stealth.ly
Twitter
[
https://issues.apache.org/jira/browse/KAFKA-1487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein resolved KAFKA-1487.
--
Resolution: Duplicate
Already a patch for this on https://issues.apache.org/jira/browse/KAFKA-1308
[
https://issues.apache.org/jira/browse/KAFKA-1308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-1308:
-
Priority: Blocker (was: Major)
Publish jar of test utilities to Maven
[
https://issues.apache.org/jira/browse/KAFKA-1456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14029274#comment-14029274
]
Joe Stein commented on KAFKA-1456:
--
I believe they are being addressed in another ticket
[
https://issues.apache.org/jira/browse/KAFKA-1487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-1487:
-
Priority: Critical (was: Major)
Affects Version/s: 0.8.1.1
Fix Version/s
Joe Stein created KAFKA-1490:
Summary: remove gradlew initial setup output from source
distribution
Key: KAFKA-1490
URL: https://issues.apache.org/jira/browse/KAFKA-1490
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-1456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein resolved KAFKA-1456.
--
Resolution: Fixed
Add LZ4 and LZ4C as a compression codec
[
https://issues.apache.org/jira/browse/KAFKA-1487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14026893#comment-14026893
]
Joe Stein commented on KAFKA-1487:
--
The test jars didn't make the gradle conversion
[
https://issues.apache.org/jira/browse/KAFKA-1477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14017534#comment-14017534
]
Joe Stein commented on KAFKA-1477:
--
1. Since this is a relatively big change
= CheckForPCIDSS and
in CheckForPCIDSS code you could do functions like verify the topic is
going over an encrypted channel return true else false, etc, whatever.
- Joe Stein
On Tue, Jun 3, 2014 at 6:12 PM, Todd Palino tpal...@linkedin.com.invalid
wrote:
I think that¹s one option. What I would offer here
://reviews.apache.org/r/22131/#comment79038
ok, then can you make that log line info instead of debug please. thanks!
- Joe Stein
On June 3, 2014, 10:53 a.m., Ivan Lyutov wrote:
---
This is an automatically generated e-mail. To reply
On June 3, 2014, 12:37 p.m., Joe Stein wrote:
core/src/main/scala/kafka/network/BlockingChannel.scala, line 80
https://reviews.apache.org/r/22131/diff/3/?file=601681#file601681line80
ok, then can you make that log line info instead of debug please.
thanks!
never mind, keep
[
https://issues.apache.org/jira/browse/KAFKA-1456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14016476#comment-14016476
]
Joe Stein commented on KAFKA-1456:
--
Looks like a good point. I have been looking through
-7-cryptographic-message-syntax-standar.htm
[4] http://en.wikipedia.org/wiki/XML_Signature
[5] http://en.wikipedia.org/wiki/PKCS_12
/***
Joe Stein
Founder, Principal Consultant
Big Data Open Source Security LLC
http://www.stealth.ly
Twitter
[
https://issues.apache.org/jira/browse/KAFKA-1456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14017149#comment-14017149
]
Joe Stein commented on KAFKA-1456:
--
it shouldn't since the imports are all within
/ZookeeperConsumerConnector.scala
https://reviews.apache.org/r/22131/#comment79005
this shouldn't change, it should be info
- Joe Stein
On June 2, 2014, 2:32 p.m., Ivan Lyutov wrote:
---
This is an automatically generated e-mail. To reply, visit:
https
/#comment79006
The old property file should be preserved with only the new additions to it
please that are required, thanks
- Joe Stein
On June 2, 2014, 2:32 p.m., Ivan Lyutov wrote:
---
This is an automatically generated e-mail
https://reviews.apache.org/r/22131/#comment79007
This file needs apache header license please
- Joe Stein
On June 2, 2014, 2:32 p.m., Ivan Lyutov wrote:
---
This is an automatically generated e-mail. To reply, visit:
https
https://reviews.apache.org/r/22131/#comment79008
this should not be part of this ticket
- Joe Stein
On June 2, 2014, 2:32 p.m., Ivan Lyutov wrote:
---
This is an automatically generated e-mail. To reply, visit:
https
://reviews.apache.org/r/22131/#comment79009
can we do this with an atomic bool instead?
- Joe Stein
On June 2, 2014, 2:32 p.m., Ivan Lyutov wrote:
---
This is an automatically generated e-mail. To reply, visit:
https
://reviews.apache.org/r/22131/#comment79010
is this change really required?
- Joe Stein
On June 2, 2014, 2:32 p.m., Ivan Lyutov wrote:
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/22131
://reviews.apache.org/r/22131/#comment79011
is this change and the ones below it, are they really required?
- Joe Stein
On June 2, 2014, 2:32 p.m., Ivan Lyutov wrote:
---
This is an automatically generated e-mail. To reply, visit
://reviews.apache.org/r/22131/#comment79012
lots of changes here. we need to have the minimal set of changes to
support the feature.
- Joe Stein
On June 2, 2014, 2:32 p.m., Ivan Lyutov wrote:
---
This is an automatically generated e-mail
Joe Stein created KAFKA-1477:
Summary: add authentication layer and initial JKS x509
implementation for brokers, producers and consumer for network communication
Key: KAFKA-1477
URL: https://issues.apache.org/jira
[
https://issues.apache.org/jira/browse/KAFKA-1478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein resolved KAFKA-1478.
--
Resolution: Fixed
I took care of this just now.
Remove spam comment from wiki
[
https://issues.apache.org/jira/browse/KAFKA-1454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein reopened KAFKA-1454:
--
Assignee: Joe Stein
Update for a Scala 2.11 build
[
https://issues.apache.org/jira/browse/KAFKA-1456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14008923#comment-14008923
]
Joe Stein commented on KAFKA-1456:
--
committed to trunk
Add LZ4 and LZ4C
On May 23, 2014, 5:28 p.m., Jun Rao wrote:
Thanks for the patch. Could we add the new codec in ProducerCompressionTest
and MessageTest too?
Sorry I missed this comment about ProducerCompressionTest the code is in
MessageTest MessageCompressionTest and yes should be in
far. I want
to-do some more testing with clients tomorrow and Friday before committing.
- Joe Stein
On May 20, 2014, 6:24 a.m., James Oliver wrote:
---
This is an automatically generated e-mail. To reply, visit:
https
://reviews.apache.org/r/21663/#comment77589
Why does the CompressionCodeMask have to change from 0x03 to 0x07 ? I see
this as a client breaking change so lets make sure this has to change. Isn't
this field is there compression or not rather than holding what the codec is?
- Joe Stein
On May 19, 2014
for this in MessageCompressionTest.scala
- Joe Stein
On May 19, 2014, 10:01 p.m., James Oliver wrote:
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/21663
://reviews.apache.org/r/21663/#comment77592
There are dozens of changes to this file. When making a patch start with a
clean trunk that you branch your changes from or however you make them. There
should only be like a line or two (comments maybe) changed in this file I think.
- Joe Stein
On May
/CompressionType.java
https://reviews.apache.org/r/21663/#comment77594
This is the id that comes back to make the COMPRESSION_CODEC_MASK type.id
work. The MASK being 1 with the type is how it works so that is why you can
keep 0x03 and not change it.
- Joe Stein
On May 19, 2014, 10:01 p.m., James
://reviews.apache.org/r/21663/#comment77615
In addition to what you added here can you also please add test cases for
the compression in MessageCompressionTest.scala thanks
- Joe Stein
On May 19, 2014, 11:39 p.m., James Oliver wrote
Joe Stein created KAFKA-1454:
Summary: Update for a Scala 2.11 build
Key: KAFKA-1454
URL: https://issues.apache.org/jira/browse/KAFKA-1454
Project: Kafka
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/KAFKA-1454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein resolved KAFKA-1454.
--
Resolution: Not a Problem
just tested a Scala 2.11.0 project and it worked
Joe Stein created KAFKA-1456:
Summary: Add LZ4 and LZ4C as a compression codec
Key: KAFKA-1456
URL: https://issues.apache.org/jira/browse/KAFKA-1456
Project: Kafka
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/KAFKA-1308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-1308:
-
Fix Version/s: 0.8.2
Publish jar of test utilities to Maven
The Apache Kafka community is pleased to announce the general availability
release of Apache Kafka 0.8.1.1.
The 0.8.1.1 is a maintenance release with bug fixes for the 0.8.1 release.
Changes in this release:
https://archive.apache.org/dist/kafka/0.8.1.1/RELEASE_NOTES.html.
Apache Kafka is
everything should be mirrored).
Thanks to everyone that got into making this release happen.
/***
Joe Stein
Founder, Principal Consultant
Big Data Open Source Security LLC
http://www.stealth.ly
Twitter: @allthingshadoop http://www.twitter.com
Joe Stein created KAFKA-1413:
Summary: bump kafka version to 0.8.1.1 in gradle.properties
Key: KAFKA-1413
URL: https://issues.apache.org/jira/browse/KAFKA-1413
Project: Kafka
Issue Type: Task
/browse/KAFKA-1413
Repository: kafka
Description
---
bump kafka version to 0.8.1.1 in gradle.properties
Diffs
-
gradle.properties 4827769a3f8e34f0fe7e783eb58e44d4db04859b
Diff: https://reviews.apache.org/r/20560/diff/
Testing
---
Thanks,
Joe Stein
[
https://issues.apache.org/jira/browse/KAFKA-1413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-1413:
-
Attachment: KAFKA-1413.patch
bump kafka version to 0.8.1.1 in gradle.properties
[
https://issues.apache.org/jira/browse/KAFKA-1413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13977161#comment-13977161
]
Joe Stein commented on KAFKA-1413:
--
Created reviewboard https://reviews.apache.org/r
601 - 700 of 1197 matches
Mail list logo
