Thanks - I am still reading to KIP and your previous KIP to see if I can
make more constructive suggestions here.
P
On Fri, Oct 13, 2023 at 11:54 PM Erik van Oosten
wrote:
Hello David,
Thanks, I am happy to hear we agree on the problem. All the tiny details
of an implementation are less imp
. 2023 à 20:44, Erik van Oosten
a écrit :
Thanks Philip,
No worries, I am not in a hurry. Knowing this is not forgotten is enough
for me. If there is anything I can do to help the process please let me
know.
Kind regards,
Erik.
Op 13-10-2023 om 20:29 schreef Philip Nee:
Hi Erik,
Sorry for
reviewing the KIP, but I also have
not forgotten about it!
In general, KIP review process can be lengthy, so I think mailing list is
the best bet to get the committer's attention.
P
On Fri, Oct 13, 2023 at 10:55 AM Erik van Oosten
wrote:
Hi client developers,
The text is updated so that it is
n. Is async
processing not something that the kafka client wants to support?
Kind regards,
Erik.
Op 25-09-2023 om 18:17 schreef Erik van Oosten:
Hi Viktor,
Good questions!
1. Auto-commits would only work with approach 1 in the KIP. Any async
solution is incompatible with auto-commits. D
n't really a problem but how would you
change work in case of async offset commits? There can be a few caveats
there as you may not know whether a commit is finished or not until your
callback is called.
Thanks,
Viktor
On Sat, Sep 23, 2023 at 4:00 PM Erik van Oosten
wrote:
Hi all,
/confluence/display/KAFKA/KIP-983%3A+Full+speed+async+processing+during+rebalance
--
Erik van Oosten
e.vanoos...@grons.nl
https://day-to-day-stuff.blogspot.com
-user:
Moreover, the "slf4j.provider" system property bypasses the service
loader mechanism for finding providers and may shorten SLF4J
initialization.
--
Erik van Oosten
e.vanoos...@grons.nl
https://day-to-day-stuff.blogspot.com
___
slf4j-us
[
https://issues.apache.org/jira/browse/KAFKA-14972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Erik van Oosten resolved KAFKA-14972.
-
Resolution: Won't Fix
> Make KafkaConsumer usable in async
[
https://issues.apache.org/jira/browse/KAFKA-14972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Erik van Oosten resolved KAFKA-14972.
-
Resolution: Won't Fix
> Make KafkaConsumer usable in async
[
https://issues.apache.org/jira/browse/KAFKA-14972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17751330#comment-17751330
]
Erik van Oosten commented on KAFKA-14972:
-
I am closing this task as won
[
https://issues.apache.org/jira/browse/KAFKA-14972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Erik van Oosten reassigned KAFKA-14972:
---
Assignee: (was: Erik van Oosten)
> Make KafkaConsumer usable in async runti
my energy elsewhere.
Kind regards,
Erik.
Op 24-07-2023 om 18:12 schreef Erik van Oosten:
Hello Xiangyuan LI,
I am not familiar with coroutines, nor with Kotlin. You will have to
work with the documentation:
https://kotlinlang.org/docs/coroutines-overview.html
However, I am familiar
it. Maybe you need a more elaborate description
to demonstrate how coroutine code run.
Erik van Oosten 于2023年7月23日周日 17:47写道:
Hi David,
> Could you elaborate a bit more on why the callbacks must be ran in
another thread vs in the invoker thread?
I have been thinking on how to explain thi
KIP based on the discussion.
Le sam. 22 juil. 2023 à 18:34, Erik van Oosten
a écrit :
Colin, Matthias, Chris,
I have expanded the use case description in KIP-944. I hope it is more
clear what we're trying to achieve.
https://cwiki.apache.org/confluence/x/chw0Dw
Kind regards,
Erik.
wiki page for KIP-957 contains more details
https://cwiki.apache.org/confluence/x/lY6zDw
This is a call for discussion. If possible I would like to include this
change in Kafka 3.6.
Any questions, comments, ideas and other additions are welcome!
Kind regards,
Erik.
--
Erik van Oosten
Colin, Matthias, Chris,
I have expanded the use case description in KIP-944. I hope it is more
clear what we're trying to achieve.
https://cwiki.apache.org/confluence/x/chw0Dw
Kind regards,
Erik.
Op 22-07-2023 om 17:23 schreef Erik van Oosten:
Hello Chris,
Thanks for elabor
mer::release methods. If we upgraded the visibility of these
methods from private to protected, it would be possible for subclasses to
implement the proposal in KIP-944, without any KIPs or other changes to the
official Java clients library.
Best,
Chris
On Sat, Jul 22, 2023 at 4:24 AM Erik van Oosten
w
possible for subclasses to
implement the proposal in KIP-944, without any KIPs or other changes to the
official Java clients library.
Best,
Chris
On Sat, Jul 22, 2023 at 4:24 AM Erik van Oosten
wrote:
Hi Matthias,
I am getting a bit frustrated here. All the concerns and questions I
have seen
ation over the radio silence. It gets
like that sometimes, and I apologize for my lack of feedback.
I’d personally like to see this lively exchange move over to the
DISCUSS thread you’d created before.
Thanks,
Kirk
On Jul 14, 2023, at 1:33 AM, Erik van Oosten
wrote:
Hi Colin,
The way I
tests that
are described in the KIP.
Kind regards,
Erik.
Op 30-06-2023 om 07:56 schreef Erik van Oosten:
[This is a resend with the correct KIP number.]
Hello developers of the Java based consumer,
I submitted https://github.com/apache/kafka/pull/13914 to fix a long
standing problem
er different use cases to demonstrate it doesn't
cause any unsafe access. I think this can be demonstrated via diagrams and
some code in the KIP.
Thanks,
P
On Sat, Jul 8, 2023 at 12:28 PM Erik van Oosten
wrote:
Hello Colin,
>> In KIP-944, the callback thread can only delegat
-944) because, concurrent
invocations are simply no longer needed. (Of course, if backward
compatibility is a goal, not all of these things can be done.)
Curious to your thoughts and kind regards,
Erik.
--
Erik van Oosten
e.vanoos...@grons.nl
https://day-to-day-stuff.blogspot.com
-Threadsafety
Kind regards,
Erik.
Op 12-07-2023 om 13:24 schreef Erik van Oosten:
Thanks Philip,
> I think this can be demonstrated via diagrams and some code in the KIP.
There are some diagrams in KIP-944. How can they be improved?
I will add some code to address the concerns around mem
ut involving the other threads.
Please consider the context which is that we are running inside the
callback of the rebalance listener. The only way to execute something
and also have a timeout on it is to run the something on another thread.
Kind regards,
Erik.
Op 08-07-2023 om 19:17 sc
he other threads.
Please consider the context which is that we are running inside the
callback of the rebalance listener. The only way to execute something
and also have a timeout on it is to run the something on another thread.
Kind regards,
Erik.
Op 08-07-2023 om 19:17 schreef Colin McCabe:
essentially the latter.
I do understand that it's frustrating to not get a quick response. However,
overall I think this one needs a lot more discussion before getting anywhere
near a vote. I will leave a -1 just as a procedural step. Maybe some of the
people working in the client area c
-2023 om 11:38 schreef Erik van Oosten:
Hello all,
I'd like to call a vote on KIP-944 Support async runtimes in consumer.
It has has been 'under discussion' for 7 days now. 'Under discussion'
between quotes, because there were 0 comments so far. I hope the KIP
is clear!
Hello all,
I'd like to call a vote on KIP-944 Support async runtimes in consumer.
It has has been 'under discussion' for 7 days now. 'Under discussion'
between quotes, because there were 0 comments so far. I hope the KIP is
clear!
KIP description: https://cwiki.apache.org/confluence/x/chw0Dw
section. As far as I
am aware there are no tests for the current behavior. Any help in this
area would be appreciated.
Kind regards,
Erik.
--
Erik van Oosten
e.vanoos...@grons.nl
https://day-to-day-stuff.blogspot.com
[
https://issues.apache.org/jira/browse/KAFKA-14972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Erik van Oosten updated KAFKA-14972:
Description:
KafkaConsumer contains a check that rejects nested invocations from
[
https://issues.apache.org/jira/browse/KAFKA-14972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Erik van Oosten updated KAFKA-14972:
Description:
KafkaConsumer contains a check that rejects nested invocations from
[
https://issues.apache.org/jira/browse/KAFKA-14972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17738014#comment-17738014
]
Erik van Oosten commented on KAFKA-14972:
-
KIP-944 https://cwiki.apache
It seems KIP-941 was already taken. Updated to: KIP-944.
Op 28-06-2023 om 10:11 schreef Erik van Oosten:
Hello developers of the Java based consumer,
I submitted https://github.com/apache/kafka/pull/13914 to fix a long
standing problem that the Kafka consumer on the JVM is not usable from
the current behavior. Any help in this
area would be appreciated.
Kind regards,
Erik.
--
Erik van Oosten
e.vanoos...@grons.nl
https://day-to-day-stuff.blogspot.com
[
https://issues.apache.org/jira/browse/KAFKA-14972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17737711#comment-17737711
]
Erik van Oosten commented on KAFKA-14972:
-
I will complete the KIP tomo
Dear reader,
I would like to create a KIP and understand I need to request
permissions for that.
my wiki username: e.vanoos...@chello.nl (note, this is /not/ my email
address)
my Jira username: erikvanoosten
Kind regards,
Erik.
--
Erik van Oosten
e.vanoos...@grons.nl
https://day-to
Dear Kafka developers,
I submitted https://github.com/apache/kafka/pull/13914 to fix a long
standing problem that the Kafka consumer on the JVM is not usable from
asynchronous runtimes such as Kotlin co-routines and ZIO.
Your review is much appreciated.
Kind regards,
Erik.
--
Erik van
[
https://issues.apache.org/jira/browse/KAFKA-10337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17730665#comment-17730665
]
Erik van Oosten commented on KAFKA-10337:
-
Thanks for your PR [~thomaslee]
Erik van Oosten created KAFKA-14972:
---
Summary: Make KafkaConsumer usable in async runtimes
Key: KAFKA-14972
URL: https://issues.apache.org/jira/browse/KAFKA-14972
Project: Kafka
Issue Type
Erik van Oosten created KAFKA-14972:
---
Summary: Make KafkaConsumer usable in async runtimes
Key: KAFKA-14972
URL: https://issues.apache.org/jira/browse/KAFKA-14972
Project: Kafka
Issue Type
Is that an acceptable
change?
Kind regards,
Erik.
Op 05-05-2023 om 20:20 schreef Philip Nee:
Hey Eric,
Maybe its more straightforward to open a new PR.
Thanks!
P
On Fri, May 5, 2023 at 9:36 AM Erik van Oosten wrote:
If I were to rebase the old pull request and re-open KAFKA-10337, w
[
https://issues.apache.org/jira/browse/KAFKA-10337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17720114#comment-17720114
]
Erik van Oosten commented on KAFKA-10337:
-
[~thomaslee] when we use commitA
[
https://issues.apache.org/jira/browse/KAFKA-10337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17720113#comment-17720113
]
Erik van Oosten commented on KAFKA-10337:
-
Opened [~thomaslee] 's
If I were to rebase the old pull request and re-open KAFKA-10337, would
it be considered for merging?
Kind regards,
Erik.
Op 03-05-2023 om 09:21 schreef Erik van Oosten:
Hi Philip,
Firstly, could you explain the situation
in that you would prefer to invoke commitAsync over commitSync
with the rebalancing,
which leads to my second comment/question. is it your concern that we
currently don't have a way to invoke the callback, and the user won't
be to
correctly handle these failed/successful async commits?
Thanks,
P
On Tue, May 2, 2023 at 12:22 PM Erik van Oosten
wrote:
would be very happy to hear
about that because it means I do not have to wait for a release cycle.
If you agree these arguments are sound, I would be happy to make the
pull request mergable again.
Curious to your thoughts and kind regards,
Erik.
--
Erik van Oosten
e.vanoos...@grons.nl
the question:
What method should I invoke (from the onPartitionsRevoked callback), to
make the Kafka client invoke the callback of earlier async commits?
Some context: I am working on zio-kafka; a completely async library that
provides a concurrent streaming layer on top of the Java client
If you want to run on JDK 11 you will need to make sure you have a
reasonably recent scala version installed. These work: 2.11.12, 2.12.11
and of course 2.13.2. It wouldn't hurt to use a recent sbt version as well.
Kind regards,
Erik.
--
Erik van Oosten
https://day-t
[
https://issues.apache.org/jira/browse/SPARK-27025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Erik van Oosten resolved SPARK-27025.
-
Resolution: Incomplete
> Speed up toLocalItera
[
https://issues.apache.org/jira/browse/SPARK-27025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16784854#comment-16784854
]
Erik van Oosten commented on SPARK-27025:
-
If there is no obvious wa
[
https://issues.apache.org/jira/browse/SPARK-27025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16783220#comment-16783220
]
Erik van Oosten edited comment on SPARK-27025 at 3/4/19 10:3
[
https://issues.apache.org/jira/browse/SPARK-27025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16783220#comment-16783220
]
Erik van Oosten commented on SPARK-27025:
-
[~hyukjin.kwon] may
[
https://issues.apache.org/jira/browse/SPARK-27025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16783110#comment-16783110
]
Erik van Oosten commented on SPARK-27025:
-
Thanks Sean, that is very us
[
https://issues.apache.org/jira/browse/SPARK-27025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16782322#comment-16782322
]
Erik van Oosten edited comment on SPARK-27025 at 3/2/19 8:4
[
https://issues.apache.org/jira/browse/SPARK-27025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16782322#comment-16782322
]
Erik van Oosten commented on SPARK-27025:
-
I have a program in which sev
Erik van Oosten created SPARK-27025:
---
Summary: Speed up toLocalIterator
Key: SPARK-27025
URL: https://issues.apache.org/jira/browse/SPARK-27025
Project: Spark
Issue Type: Wish
.
--
Erik van Oosten
http://www.day-to-day-stuff.blogspot.com/
-
To unsubscribe e-mail: user-unsubscr...@spark.apache.org
Hi sohimankotia,
My advise from also having to sub-class BucketingSink:
* rebase your changes on the BucketingSink that comes with the Flink
version you are using
* use the same super completely ugly hack I had to deploy as described
here:
http://apache-flink-user-mailing-list-archive.2336050
[
https://issues.apache.org/jira/browse/KAFKA-960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16585713#comment-16585713
]
Erik van Oosten commented on KAFKA-960:
---
Metrics 4.x was released not so long
[
https://issues.apache.org/jira/browse/FLINK-5633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16245474#comment-16245474
]
Erik van Oosten commented on FLINK-5633:
bq. Just curious, why are you creati
[
https://issues.apache.org/jira/browse/FLINK-5633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16241701#comment-16241701
]
Erik van Oosten commented on FLINK-5633:
[~StephanEwen] We need to process
Hi Wangsan,
We were struggling with this for many days as well. In the end we found a work
around. Well work-around, this for sure qualifies as one of the ugliest hacks I
have ever contemplated. Our work-around for Flink immediately interrupting the
close, is to continue closing on another thre
[
https://issues.apache.org/jira/browse/AVRO-2076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16167422#comment-16167422
]
Erik van Oosten commented on AVRO-2076:
---
Awesome! Thanks Doug. Somehow I missed
[
https://issues.apache.org/jira/browse/AVRO-2076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Erik van Oosten resolved AVRO-2076.
---
Resolution: Not A Problem
> Combine already serialized Avro records to an Avro f
[
https://issues.apache.org/jira/browse/FLINK-4796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16166443#comment-16166443
]
Erik van Oosten commented on FLINK-4796:
I am not sure why this is marked
Erik van Oosten created AVRO-2076:
-
Summary: Combine already serialized Avro records to an Avro file
Key: AVRO-2076
URL: https://issues.apache.org/jira/browse/AVRO-2076
Project: Avro
Issue
[
https://issues.apache.org/jira/browse/FLINK-4796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16160810#comment-16160810
]
Erik van Oosten commented on FLINK-4796:
A workaround is to over
[
https://issues.apache.org/jira/browse/FLINK-1390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16058708#comment-16058708
]
Erik van Oosten commented on FLINK-1390:
See
https://issues.apache.org/
[
https://issues.apache.org/jira/browse/FLINK-5633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16058706#comment-16058706
]
Erik van Oosten commented on FLINK-5633:
In case you need throughput (like w
[
https://issues.apache.org/jira/browse/FLINK-6928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16050925#comment-16050925
]
Erik van Oosten edited comment on FLINK-6928 at 6/15/17 6:3
[
https://issues.apache.org/jira/browse/FLINK-6928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16050925#comment-16050925
]
Erik van Oosten commented on FLINK-6928:
In my ideal world me
[
https://issues.apache.org/jira/browse/FLINK-6928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Erik van Oosten updated FLINK-6928:
---
Description:
When using a Kafka sink, the defaultTopic needs to exist even when it is never
[
https://issues.apache.org/jira/browse/FLINK-6928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Erik van Oosten updated FLINK-6928:
---
Description:
When using a Kafka sink, the defaultTopic needs to exist even when it is never
[
https://issues.apache.org/jira/browse/FLINK-6928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Erik van Oosten updated FLINK-6928:
---
Summary: Kafka sink: default topic should not need to exist (was: Kafka
source: default
[
https://issues.apache.org/jira/browse/FLINK-6928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Erik van Oosten updated FLINK-6928:
---
Description:
When using a Kafka sink, the defaultTopic needs to exist even when it is never
[
https://issues.apache.org/jira/browse/FLINK-6928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Erik van Oosten updated FLINK-6928:
---
Summary: Kafka source: default topic should not need to exist (was: Kafka
source: default
Erik van Oosten created FLINK-6928:
--
Summary: Kafka source: default topic needs to exist
Key: FLINK-6928
URL: https://issues.apache.org/jira/browse/FLINK-6928
Project: Flink
Issue Type: Bug
Erik van Oosten created FLINK-6928:
--
Summary: Kafka source: default topic needs to exist
Key: FLINK-6928
URL: https://issues.apache.org/jira/browse/FLINK-6928
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/AVRO-2022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16021085#comment-16021085
]
Erik van Oosten commented on AVRO-2022:
---
After working with this change for
[
https://issues.apache.org/jira/browse/AVRO-2022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Erik van Oosten resolved AVRO-2022.
---
Resolution: Invalid
> IDL does not allow `schema` as identif
[
https://issues.apache.org/jira/browse/AVRO-2022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Erik van Oosten updated AVRO-2022:
--
Description:
The keyword {{schema}} is now allowed as escaped identifier in IDL. E.g. the
Erik van Oosten created AVRO-2022:
-
Summary: IDL does not allow `schema` as identifier
Key: AVRO-2022
URL: https://issues.apache.org/jira/browse/AVRO-2022
Project: Avro
Issue Type: Bug
.
Happy coding and kind regards,
Erik.
--
Erik van Oosten
https://day-to-day-stuff.blogspot.nl/
[
https://issues.apache.org/jira/browse/THRIFT-3867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Erik van Oosten updated THRIFT-3867:
Comment: was deleted
(was: Pull request in https://github.com/apache/thrift/pull/1036
[
https://issues.apache.org/jira/browse/THRIFT-3867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15355043#comment-15355043
]
Erik van Oosten commented on THRIFT-3867:
-
Pull request in https://github
Erik van Oosten created THRIFT-3867:
---
Summary: Specify BinaryProtocol and CompactProtocol
Key: THRIFT-3867
URL: https://issues.apache.org/jira/browse/THRIFT-3867
Project: Thrift
Issue Type
[
https://issues.apache.org/jira/browse/SPARK-6878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Erik van Oosten updated SPARK-6878:
---
Flags: Patch
> Sum on empty RDD fails with except
[
https://issues.apache.org/jira/browse/SPARK-6878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14492336#comment-14492336
]
Erik van Oosten commented on SPARK-6878:
Pull request: https://github.com/ap
[
https://issues.apache.org/jira/browse/SPARK-6878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14492302#comment-14492302
]
Erik van Oosten commented on SPARK-6878:
Ah, yes. I now see that fold also f
[
https://issues.apache.org/jira/browse/SPARK-6878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14492282#comment-14492282
]
Erik van Oosten edited comment on SPARK-6878 at 4/13/15 11:1
[
https://issues.apache.org/jira/browse/SPARK-6878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14492282#comment-14492282
]
Erik van Oosten commented on SPARK-6878:
The answer is only defined because
Erik van Oosten created SPARK-6878:
--
Summary: Sum on empty RDD fails with exception
Key: SPARK-6878
URL: https://issues.apache.org/jira/browse/SPARK-6878
Project: Spark
Issue Type: Bug
The problem has not gone away. I guess this package could use a new
maintainer.
--
You received this bug notification because you are a member of Ubuntu
Bugs, which is subscribed to Ubuntu.
https://bugs.launchpad.net/bugs/1388955
Title:
POODLE vulnerability because SSL3 can not be disabled
To
[
https://issues.apache.org/jira/browse/KAFKA-960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14194990#comment-14194990
]
Erik van Oosten commented on KAFKA-960:
---
If 2.20 and 2.1.5 are indeed bi
Public bug reported:
Please upgrade pound package to the latest mainstream release (2.7d) so that
SSL3 can be disabled.
SSL3 needs to be disabled because of the POODLE vulnerability.
More details around other options on
http://www.apsis.ch/pound/pound_list/archive/2014/2014-10/1414097953000
Tha
[
https://issues.apache.org/jira/browse/KAFKA-960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14194883#comment-14194883
]
Erik van Oosten commented on KAFKA-960:
---
Fixing the issue where Mbean names
? So,
instead of
"kafka.server":type="BrokerTopicMetrics",name="topic-1-BytesInPerSec"
we will have
kafka.server:type=BrokerTopicMetrics,name=BytesInPerSec,topic=topic-1
Thanks,
Jun
--
Erik van Oosten
http://www.day-to-day-stuff.blogspot.com/
Erik.
Steven Wu schreef op 22-10-14 om 01:48:
I think it doesn't have to be two more clusters. can be just two more
topics. MirrorMaker can copy from source topics in both regions into one
aggregate topic.
On Tue, Oct 21, 2014 at 1:54 AM, Erik van oosten <
e.vanoos...@grons.nl.i
pies data from both the DC's local clusters into the aggregate
> clusters. So if you want access to a topic with data from both DC's, you
> subscribe to the aggregate cluster.
>
> Thanks,
> Neha
>
> On Mon, Oct 20, 2014 at 7:07 AM, Erik van oosten <
>
mirroring to a topic with
another name.
Is there another tool we could use?
Or, is there another approach for producing and consuming from 2 DCs?
Kind regards,
Erik.
—
Erik van Oosten
http://www.day-to-day-stuff.blogspot.nl/
1 - 100 of 1166 matches
Mail list logo