Re: Is the KafkaStreams#store() method thread-safe?

You need to wrap Hashmap with ConcurrentHashMap imlementation otherwise you will receive no Thread Notifications Sent from my Verizon, Samsung Galaxy smartphone Get Outlook for Android From: Kohei Nozaki Sent: Wednesday, December 27, 2023

Re: [ANNOUNCE] New Committer: Chris Egerton

Congratulations Chris! martin~ From: Mickael Maison Sent: Monday, July 25, 2022 12:25 PM To: dev ; Users Subject: [ANNOUNCE] New Committer: Chris Egerton Hi all, The PMC for Apache Kafka has invited Chris Egerton as a committer, and we are excited to announce

Re: securing sasl/scram username and password in kafka connect

Hi Mem UNIX / Linux Find File Owner Name - nixCraft (cyberciti.biz) once you know who created your file file:/app/data/cred/connector_credentials.prop you will need to change credentials as the owner of the file then follow chris'

Re: How to configure Spring Boot Kafka client so it does not try to connect

Honza did you try to set zookeeper.connection.timeout.ms.to 0 ? Apache Kafka [http://apache-kafka.org/images/apache-kafka.png] Apache

Re: Accessing TLS certs and keys from Vault into Kafka

all JRE will look in the truststore for your certificates and keys Generating a KeyStore and TrustStore (Configuring Java CAPS for SSL Support) (oracle.com) You will need to lookup specific "create truststore" capability for

Re: [ANNOUNCE] New Kafka PMC Member: Bill Bejeck

Congratulations Bill! martin From: Bruno Cadonna Sent: Monday, April 12, 2021 6:58 AM To: d...@kafka.apache.org ; Kafka Users Subject: Re: [ANNOUNCE] New Kafka PMC Member: Bill Bejeck Congrats Bill! Well deserved! Best, Bruno On 12.04.21 11:19, Satish

Re: Unable to run unit tests inside a docker container

is not known. This is the version I'm using inside my container *bash-4.4$ which scala/usr/bin/scalabash-4.4$ scala -versionScala code runner version 2.12.13 -- Copyright 2002-2020, LAMP/EPFL and Lightbend, Inc.* On Mon, Feb 8, 2021 at 4:02 PM Martin Gainty wrote: > scala plugin is not access

Re: Unable to run unit tests inside a docker container

748> On Fri, Feb 5, 2021 at 1:31 AM Martin Gainty wrote: > * What went wrong: > 18:54:25.681 [ERROR] > [org.gradle.internal.buildevents.BuildExceptionReporter] > A problem occurred evaluating root project 'stephin'. > > 18:54:25.681 [ERROR] > [org.gradle.internal.buildevents

Re: Unable to run unit tests inside a docker container

test/java/org/apache/kafka/common/network/SslVersionsTransportLayerTest.java>Here is the upstream link to the SslTransportLayerTest.java <https://github.com/apache/kafka/blob/trunk/clients/src/test/java/org/apache/kafka/common/network/SslTransportLayerTest.java> , I've used. Thanks for looking into this. -Step

Re: Unable to run unit tests inside a docker container

n/network/SslTransportLayerTest.java> , I've used. Thanks for looking into this. -Stephin On Wed, Feb 3, 2021 at 11:11 PM Martin Gainty wrote: > authentication fail > > using basic-authentication you will need to supply correct > username/password > try ssh to server with supplie

Re: Unable to run unit tests inside a docker container

. https://gist.github.com/STEPHINRACHEL/b67f34e6ff1b3deb5338e8b6fb6b48ee#file-kafka-test-14-40-L10212 Thanks -Stephin On Wed, Feb 3, 2021 at 11:52 AM Martin Gainty wrote: > one of the commiters changed all maven builds to gradle and now there are > fails that produce non-traceable error code

Re: Unable to run unit tests inside a docker container

g the test locally on my machine. Is there any minimum memory requirement for the container? Thank you in advance, - Stephin On Tue, Feb 2, 2021 at 4:16 PM Martin Gainty wrote: > there are 2 things you will notice from your stacktrace > > consumerClient = new ConsumerNetworkClient(

Re: Unable to run unit tests inside a docker container

there are 2 things you will notice from your stacktrace consumerClient = new ConsumerNetworkClient(client, metadata, time, 100, 1000); your 10k request timeout is too short so why not increase 1ms to something more reasonable the specific testcase (which i do not have) is trying to

Re: Configuring the following properties in confluent cloud

kevin- in the producer initialisation code you can set SSL properties via System.setProperty System.setProperty("java.protocol.handler.pkgs","com.sun.net.ssl.internal.www.protocol"); Security.addProvider(new com.sun.net.ssl.internal.ssl.Provider()); // uncomment the following code to turn on

Re: Configuring the following properties in confluent cloud

in the producer initialisation code set via System.setProperty e.g. From: Kevin Perera Sent: Tuesday, August 6, 2019 10:21 AM To: users@kafka.apache.org Subject: Configuring the following properties in confluent cloud Hello! I'm trying to set up confluent cloud

Re: Site Issues

thanks tristan! From: Tristan Lannigan Sent: Wednesday, July 31, 2019 9:56 AM To: users@kafka.apache.org Subject: Site Issues Hi there, I found a grammatical error on https://kafka.apache.org/uses

Re: Site Issues

From: Tristan Lannigan Sent: Wednesday, July 31, 2019 9:56 AM To: users@kafka.apache.org Subject: Site Issues Hi there, I found a grammatical error on https://kafka.apache.org/uses

Re: TLS Communication in With Zookeeper Cluster

having one node. Regards, Soumya -Original Message----- From: Martin Gainty Sent: Tuesday, July 30, 2019 5:21 PM To: users@kafka.apache.org Subject: Re: TLS Communication in With Zookeeper Cluster MG>definitely implement 3.5 ZK+ as suggested From: Nayak, So

Re: TLS Communication in With Zookeeper Cluster

MG>definitely implement 3.5 ZK+ as suggested From: Nayak, Soumya R. Sent: Tuesday, July 30, 2019 6:41 AM To: users@kafka.apache.org Subject: TLS Communication in With Zookeeper Cluster Thanks Harsha for the link. As I am using a zookeeper cluster. In the below

Re: TLS Communication in With Zookeeper Cluster

MG>below From: Nayak, Soumya R. Sent: Monday, July 29, 2019 4:20 AM To: users@kafka.apache.org Subject: TLS Communication in With Zookeeper Cluster Hi Team, Is there any way mutual TLS communication set up can be done with zookeeper. If any references, can

Re: topic admin over SSL/SASL

; > Thanks, > Chris > > > > On Fri, Jul 19, 2019 at 11:57 AM Martin Gainty > wrote: > >> MG>below >> >> >> From: Chris Constantin >> Sent: Friday, July 19, 2019 2:09 PM >> To: users@kafka.apache.org >

Re: topic admin over SSL/SASL

l cause kafka-topics.sh/TopicAdmin to connect to the > cluster via SSL/SASL. Is that correct? MG>interbroker uses a different property specifically MG>security.inter.broker.protocol=SASL_PLAINTEXT (or SASL_SSL) > > Thanks, > Chris MG>HTH > > &g

Re: topic admin over SSL/SASL

MG>below From: Chris Constantin Sent: Friday, July 19, 2019 2:09 PM To: users@kafka.apache.org Subject: topic admin over SSL/SASL Hi, How can the security.protocol config can be passed in to 'kafka-topics'/TopicAdmin when creating topics? I can pass in

Re: First time building a streaming app and I need help understanding how to build out my use case

MG>below From: Simon Calvin Sent: Friday, June 7, 2019 3:39 PM To: users@kafka.apache.org Subject: First time building a streaming app and I need help understanding how to build out my use case Hello, everyone. I feel like I have a use case that it is well

Re: Unable to build

in build.gradle assuming sourceSets is defined as sourceSets { main { java { srcDirs = ['src/java'] } resources { srcDirs = ['src/resources'] } } } add missing source files:

Re: Gradle Build Fails when forked from Trunk

y your proposed solution above. > > Thanks, > > On Mon, 20 May 2019 at 01:44, Martin Gainty wrote: > >> with regards to missing plugin >> classpath 'org.scoverage:gradle-scoverage:2.0.1' >> >> must be located in the following repositories: >> >

Re: Gradle Build Fails when forked from Trunk

with regards to missing plugin classpath 'org.scoverage:gradle-scoverage:2.0.1' must be located in the following repositories: buildscript { repositories { mavenCentral() jcenter() } From: M. Manna Sent: Sunday, May 19, 2019 4:22 AM To: Kafka Users

Re: Gradle Build Fails when forked from Trunk

with regards to classpath 'org.scoverage:gradle-scoverage:2.0.1' From: M. Manna Sent: Sunday, May 19, 2019 4:22 AM To: Kafka Users Subject: Gradle Build Fails when forked from Trunk Hello, I am trying to run gradle build on a forked repo from trunk. It seems

Re: Gradle Build Fails when forked from Trunk

Re: Question about Kafka TLS

trust-store AKA $JAVA_HOME/lib/security/cacerts is the system-wide location for all of your certificates when your CA-server starts up unless otherwise specified CA-Server will lookup root cert(s) in truststore/cacerts if you have not installed all your root-certs into cacerts you should do so

Re: SASL + SSL : authentication error in broker-to-broker communication

ing my ps faux, you can see that Kafka is using the jaas file as documentation is advising : -Djava.security.auth.login.config=/opt/kafka/config/kafka_server_jaas.conf I also checked that every zookeeper is able to answer the same salt, server_key for each user described. Anything else to

Re: SASL + SSL : authentication error in broker-to-broker communication

k ? Thanks a lot. Sincerely, Kieran ________ From: Martin Gainty Sent: Wednesday, May 15, 2019 2:28 PM To: users@kafka.apache.org Subject: Re: SASL + SSL : authentication error in broker-to-broker communication assuming ScramSaslProvider/ScramSaslServer your credentials are store

Re: SASL + SSL : authentication error in broker-to-broker communication

assuming ScramSaslProvider/ScramSaslServer your credentials are stored in ZK /config/users/ but you cannot see plain-text attributes in ZK so use kafka tool to view kafka-configs.sh -describe /config/users/ /*2019 update for kafka-configs.sh */ For ease of use, kafka-configs.sh will take a

Re: [ANNOUNCE] New Kafka PMC member: Matthias J. Sax

wilkommen matthias Martin- From: Bill Bejeck Sent: Thursday, April 18, 2019 5:45 PM To: users@kafka.apache.org Cc: dev Subject: Re: [ANNOUNCE] New Kafka PMC member: Matthias J. Sax Congrats Matthias! Well deserved! -Bill On Thu, Apr 18, 2019 at 5:35 PM

Re: Proxying the Kafka protocol

mg>that depends on the underlying protocol you are attempting to proxy (see below) From: James Grant Sent: Monday, March 25, 2019 1:21 PM To: users@kafka.apache.org Subject: Re: Proxying the Kafka protocol Thank you all. We have in the past exposed message

Re: [ANNOUNCE] New Committer: Randall Hauch

willkommen randall Martin From: Daniel Hanley Sent: Friday, February 15, 2019 6:55 AM To: users@kafka.apache.org Cc: dev Subject: Re: [ANNOUNCE] New Committer: Randall Hauch Congratulations Randall! On Fri, Feb 15, 2019 at 9:35 AM Viktor Somogyi-Vass wrote:

Re: [ANNOUNCE] New Committer: Bill B

and a hearty congratulations on your recent win welcome bill! Martin From: Ivan Ponomarev Sent: Thursday, February 14, 2019 5:25 AM To: d...@kafka.apache.org; users@kafka.apache.org Subject: Re: [ANNOUNCE] New Committer: Bill Bejeck Congratulations, Bill!

Re: Kafka SSL and multiple domain names

if you require security over multiple subject alt names then you will need a UCC certificate from cert-provider (godaddy/thawte/verisign are some of the providers) https://www.techopedia.com/definition/29764/unified-communications-certificate-ucc

Re: [ANNOUNCE] New Committer: Vahid Hashemian

Բարի գալուստ (Bari Galust) From: Satish Duggana Sent: Tuesday, January 15, 2019 7:54 PM To: dev Cc: Kafka Users Subject: Re: [ANNOUNCE] New Committer: Vahid Hashemian Congratulations Vahid! On Tue, Jan 15, 2019 at 5:47 PM Yishun Guan wrote: > >

Re: Kafka Trunk Build Failure with Gradle 5.0

there are at least 12 things that can go wrong with any gradle build if you can provider a link to the source-tree you are building we can be narrow down the reasons you are experiencing NoSuchMethodError for version of Kafka T & R From: Boyang Chen Sent:

Re: How to provide certificate chain/intermediate CA to kafka broker

if you dont have a "certs team" you can purchase a Contract with Certificate Authority such as Verisign to handle signing X509 certs Once the certs are signed and stuffed into truststore(s) you will then be able to supply the x509 cert with public key from CA to your clients Martin

Re: [ANNOUNCE] New committer: Colin McCabe

welcome and congratulations Colin Martin From: Konstantine Karantasis Sent: Wednesday, September 26, 2018 1:03 PM To: d...@kafka.apache.org Cc: users@kafka.apache.org Subject: Re: [ANNOUNCE] New committer: Colin McCabe Well deserved! Congratulations Colin.

Re: Real time streaming as a microservice

sponsibility for any loss, damage or destruction of data or any other property which may arise from relying on this email's technical content is explicitly disclaimed. The author will in no case be liable for any monetary damages arising from such loss, damage or destruction. On Sun, 8 Jul 201

Re: Real time streaming as a microservice

initial work under using Zookeeper as a Microservices container is here http://planet.jboss.org/post/zookeeper_for_microservice_registration_and_discovery ZooKeeper for Microservice Registration and Discovery

Re: Configuring Kerberos behind an ELB

Wood Cc: users@kafka.apache.org; Martin Gainty Subject: Re: Configuring Kerberos behind an ELB Ben, Yes. I want to be able to provide consumers/producers with a single address they can use to connect to the cluster. Having it behind an elb lets us scale up and replace nodes with out needing

Re: Configuring Kerberos behind an ELB

MG>quoting stackoverflow below "You can use an ELB as the bootstrap.servers, The ELB will be used for the initial metadata request the client makes to figure out which topic partitions are on which brokers, but after (the initial metadata request) the brokers still need to be directly accessible

Re: Migration Path from 0.8

From: Martín Fernández Sent: Monday, June 18, 2018 4:38 PM To: users@kafka.apache.org Subject: Migration Path from 0.8 Hello, First time writing in the mailing list! At this moment we are running 3 Kafka (0.8) broker cluster. We want to try to upgrade our

new pom.xml for samza-parent-project

Martin Gainty has shared a OneDrive file with you. To view it, click the link below. <https://1drv.ms/u/s!AkpuiYcNg4cShUb8oiOENPhRhIUV> [https://r1.res.office365.com/owa/prem/images/dc-generic_20.png]<https://1drv.ms/u/s!AkpuiYcNg4cShUb8oiOENPhRhIUV> pom 1.xml<http

new pom.xml for samza-grid

Martin Gainty has shared a OneDrive file with you. To view it, click the link below. <https://1drv.ms/u/s!AkpuiYcNg4cShUUyzyKvQmvyNPuk> [https://r1.res.office365.com/owa/prem/images/dc-generic_20.png]<https://1drv.ms/u/s!AkpuiYcNg4cShUUyzyKvQmvyNPuk> pom.xml<http

Re: NoClassDefFoundError TopicExistxException Samza 0.14.2 and Kafka 0.10.0.0

] \- org.apache.kafka:kafka_2.11:jar:0.10.0.0:runtime On Fri, Jun 15, 2018 at 8:31 PM, Martin Gainty wrote: > a strong possibility is that kafka-core is missing as a dependency for > samza > > please supply samza pom.xml

Re: NoClassDefFoundError TopicExistxException Samza 0.14.2 and Kafka 0.10.0.0

a strong possibility is that kafka-core is missing as a dependency for samza please supply samza pom.xml Martin __ From: Debraj Manna Sent: Friday, June 15, 2018 10:52 AM To: users@kafka.apache.org Subject:

Re: Custom AuthenticateCallbackHandler

return (String) val; } return null; } MG>so JAAS password where expected_password= user_admin MG>but your password where expected_password = user_test MG>any reason you need to implement username/password test/test instead of admin/admin ? Any hel

Re: Custom AuthenticateCallbackHandler

are you referring to onCompleteCallback from https://github.com/apache/kafka/commit/837f31dd1850b179918f83338b4b4487486b2c58 [https://avatars2.githubusercontent.com/u/14958864?s=200=4] KAFKA-6927; Chunked

Re: Exactly Once, Producer configuration

From: thomas.k...@t-systems.com Sent: Monday, May 14, 2018 12:13 PM To: users@kafka.apache.org Subject: WG: Exactly Once, Producer configuration Hi, the following article describes how to configure Apache Kafka system to enforce

Re: Kafka Scala debugging and diagnostics

supposedly scala ide for eclipse should work: http://scala-ide.org/ YMMV Martin From: M. Manna Sent: Wednesday, May 16, 2018 5:46 PM To: Kafka Users Subject: Kafka Scala debugging and diagnostics Hello, Is there anyone who can provide a

Re: Kafka as K/V store

//best to do your generic type declaration at class level and refer to later KafkaConsumer consumer = new KafkaConsumer<>(props); //best to do generic type declaration at class level and refer to later java.util.HashMap hashMap=new java.util.HashMap();

Re: Log Cleanup Support for Windows [KAFKA-1194]

a patch could be rejected if: 1)there is no TestCase to prove the feature works 2)the patch causes failure in an existing testcase 3)the patch errors in an existing testcase 4)the patch works in only 1 version of OS (and doesnt work in other versions of OS) 5)implementing the patch will place a

Re: Using Kafka CLI without specifying the URLs every single time?

Hello Péter : etc/hosts PUBLIC_IP_ADDRESS FQDN SHORTNAME where shortname can be your shortened HostName (Nota Bene: be respectful of tabs, spaces and are important...best to make backup before modify)

Re: Kafka using existing certificate authority.

MG>below From: Shawn Raymond Sent: Tuesday, April 17, 2018 10:25 AM To: users@kafka.apache.org Subject: Kafka using existing certificate authority. I am trying to set up apache kafka using an existing certificate authority, and I cannot find

Re: advertised.listeners

llows for a more efficient allocation of IP addresses than the older method which was by assigning organizations a class of IPs. MG>if you dont want network segmentation you can config your Kafka ACLs explained here: https://docs.confluent.io/3.0.0/kafka/platform-security.html MG>HTH Jo

Re: advertised.listeners

ail.com> Sent: Tuesday, April 3, 2018 6:47 PM To: users@kafka.apache.org Subject: Re: advertised.listeners We are using 0.10.2.1 and ZK 3.4.9. Can something be derived from this piece of info ? Thanks. On Tue, Apr 3, 2018 at 3:13 PM, Martin Gainty <mgai...@hotmail.com> wrote: > tracert Mess

Re: advertised.listeners

tracert MessageBrokerIP do you see ZK server in the trace? if yes then you are running kafka-cluster (ZK does not support mixed mode but there is a backdoor zookeeper.properties config attribute that allows plaintext clients to bypass sasl auth) ? Martin

Re: Making a Window services for kafka having sasl and ssl configuration

From: ashish chauhan Sent: Tuesday, April 3, 2018 4:16 AM To: users@kafka.apache.org Subject: Making a Window services for kafka having sasl and ssl configuration I am trying to make Window services for kafka having sasl and ssl

Re: Possible to enable client SSL when PLAINTEXT brokers exist in the cluster?

FWIR: is a plaintext broker supported with SASL Zookeeper frontend..assuming no here are the reasons: https://www.tutorialspoint.com/apache_kafka/apache_kafka_cluster_architecture.htm

Please disregard last message

All Kindly disregard last message Thank You Martin __ From: Martin Gainty <mgai...@hotmail.com> Sent: Thursday, March 22, 2018 1:13 PM To: users@kafka.apache.org Subject: Re: kafka offset replication factor

Re: kafka offset replication factor - Any suggestion will be appreciated.

that toilet-shutoff-valve water pan gets emptied into sink every day Its a shame I cant get thru to your gf but I'll let you handle that Rest assured we'll get thru this Martin Gainty __ From: adrien ruffie <adrienno

Re: Vids Re: Running SSL and PLAINTEXT mode together (Kafka 10.2.1)

From: svsuj...@gmail.com Sent: Sunday, March 11, 2018 4:22 PM To: users@kafka.apache.org Cc: Ismael Juma; rajinisiva...@gmail.com Subject: Vids Re: Running SSL and PLAINTEXT mode together (Kafka 10.2.1) Chic bhari Sent from my iPhone GC

Re: Consultant Help

From: Svante Karlsson Sent: Friday, March 2, 2018 3:50 PM To: users@kafka.apache.org Subject: Re: Consultant Help try https://www.confluent.io/ - that's what they do

Re: Static IP Configuration

on of devices, sensors, application hence volume of producers would be high. All I want to ensure Broker receives data from trusted (my own) devices. On Fri, Feb 16, 2018 at 9:33 AM, Martin Gainty <mgai...@hotmail.com> wrote: > majority of commercial entities (banks/financial-houses)

Re: Static IP Configuration

majority of commercial entities (banks/financial-houses) pass this to a CA (certifying authority) who will be responsible for generating X509 certificates generating private key generating public key generating username (aka alias) generating password this depends on what type of PKI your client

Re: Question Related to Zookeeper and kafka java error message.

From: Raymond, Shawn P CTR USARMY NETCOM (US) Sent: Thursday, February 8, 2018 2:39 PM To: users@kafka.apache.org Subject: Question Related to Zookeeper and kafka java error message. Afternoon all, I was wondering if anyone has

Re: I would like to increase the bandwidth by binding each broker to each network card in one machine. Is this feasible?

From: 猪少爷 Sent: Tuesday, January 16, 2018 8:21 PM To: users Subject: I would like to increase the bandwidth by binding each broker to each network card in one machine. Is this feasible? I would like to increase the bandwidth by

Re: [ANNOUNCE] New committer: Matthias J. Sax

Willkommen Matthias! Martin- From: Damian Guy Sent: Friday, January 12, 2018 7:43 PM To: users@kafka.apache.org Cc: dev Subject: Re: [ANNOUNCE] New committer: Matthias J. Sax Can't think of anyone me deserving! Congratulations Matthias! On

Re: Kafka SSL error

possible you are either not connecting (someone is blocking/redirecting) or possibly you are not authenticating with your security configuration parameters: are your redirecting to other IP's or Ports by intervening proxys? can you ping all the IP addresses in the cluster? can u post the

Re: SSL setup in Kafka 2.10.0.10.2.1 for keystore and truststore files

From: Awadhesh Gupta Sent: Tuesday, October 3, 2017 1:44 PM To: users@kafka.apache.org; ja...@scholz.cz Subject: Re: SSL setup in Kafka 2.10.0.10.2.1 for keystore and truststore files Hi, I validated the client chain in server log

Re: SSL setup in Kafka 2.10.0.10.2.1 for keystore and truststore files

From: Awadhesh Gupta Sent: Friday, September 29, 2017 7:05 AM To: users@kafka.apache.org; manme...@gmail.com Subject: Re: SSL setup in Kafka 2.10.0.10.2.1 for keystore and truststore files Thanks M Manna. I followed the steps to

Re: Federated Alerting for Prometheus, Elasticsearch and Apache Kafka systems

From: Lucas Ponce Sent: Thursday, August 17, 2017 10:18 AM To: users@kafka.apache.org Subject: Federated Alerting for Prometheus, Elasticsearch and Apache Kafka systems Hello, >From Hawkular team we are working to create a

Re: How to debug - NETWORK_EXCEPTION

From: Raghav Sent: Thursday, August 10, 2017 12:51 AM To: Users; confluent-platf...@googlegroups.com Subject: How to debug - NETWORK_EXCEPTION Hi I am sending very small 32 byte message to Kafka broker in a tight loop with 250ms sleep. I

Re: Socks proxy

From: Jay Allen Sent: Friday, July 28, 2017 12:09 PM To: users@kafka.apache.org Subject: Socks proxy Hey guys, We're trying to use the Java Kafka client but it turns out it's not socks proxy aware - the connect uses a SocketChannel that

Re: [ERICSSON] - Trade Compliance: ECCN code for Apache Items

MG>am requesting clarification below From: Axelle Margot Sent: Tuesday, June 27, 2017 8:48 AM To: users@kafka.apache.org Cc: Celine Heerdt; Wassila BenJelloul.ext; Florent Poulain Subject: [ERICSSON] - Trade Compliance: ECCN code for

Re: [ANNOUNCE] New committer: Damian Guy

congratulations damian! Martin From: Gwen Shapira Sent: Friday, June 9, 2017 4:55 PM To: users@kafka.apache.org Cc: d...@kafka.apache.org; priv...@kafka.apache.org Subject: Re: [ANNOUNCE] New committer: Damian Guy Congratulations :) On

Re: Kafka Over TLS Error - Failed to send SSL Close message - Broken Pipe

From: IT Consultant <0binarybudd...@gmail.com> Sent: Friday, June 2, 2017 11:02 AM To: users@kafka.apache.org Subject: Kafka Over TLS Error - Failed to send SSL Close message - Broken Pipe Hi All, I have been seeing below error since three days , Can you please

Re: why is it called kafka?

an intelligent, creative and versatile writer who spoke 3 languages, had a background in chemistry and invented the hardhat I wonder how Kafkas stance on giving voice to individuals standing against obtuse bureaucracies would fare today ? Something to consider Martin

Re: about java.io.EOFException / java.lang.ClassNotFoundException: kafka.common.OffsetOutOfRangeException

From: Selina Tech Sent: Friday, March 17, 2017 9:02 PM To: users@kafka.apache.org Subject: about java.io.EOFException / java.lang.ClassNotFoundException: kafka.common.OffsetOutOfRangeException Hi: I am processing on a new Kafka

Re: Security Documentation contradiction / misleading ?

MG>confusion between JAAS-security terminology and Kafka-SASL terminology? From: Stephane Maarek Sent: Sunday, February 19, 2017 7:28 PM To: users@kafka.apache.org Subject: Security Documentation contradiction / misleading ? Hi,

Re: KIP-119: Drop Support for Scala 2.10 in Kafka 0.11

because: kafka will always be plagued by synchronisation issues between scala and java codebases: Scala consistently fails converting Java generics (necessitating manual conversion from scala to Java) +1 to drop Scala 2.10 (non-binding) Martin

Re: Anyone have guide for setting up the rest proxy using SSL and Client authentication

ntral Expressway I Suite 1400 I Dallas, TX 75231 -Original Message- From: Martin Gainty [mailto:mgai...@hotmail.com] Sent: Wednesday, February 01, 2017 3:56 PM To: users@kafka.apache.org Subject: Re: Anyone have guide for setting up the rest proxy using SSL and Client authentication Unfortunately

Re: Anyone have guide for setting up the rest proxy using SSL and Client authentication

, Site Operations Match.com 8750 North Central Expressway I Suite 1400 I Dallas, TX 75231 -Original Message- From: Martin Gainty [mailto:mgai...@hotmail.com] Sent: Wednesday, February 01, 2017 12:54 PM To: users@kafka.apache.org Subject: Re: Anyone have guide for setting up the rest proxy

Re: Anyone have guide for setting up the rest proxy using SSL and Client authentication

probably fighting an uphill battle sending cleartext POSTS and GETS with REST calls most apache server folk who secure HTTP 1.1 server will front end with CA (provided by thawte,verisign,GeoTrust) https://www.geotrust.com

Re: [ANNOUNCE] New committer: Grant Henke

viel gluck Herr Henke! Martin __ From: James Cheng Sent: Wednesday, January 11, 2017 5:37 PM To: users@kafka.apache.org Cc: d...@kafka.apache.org; priv...@kafka.apache.org Subject: Re:

Re: Kafka SSL encryption plus external CA

run openssl on your cert and pipe to grep or awk to look for Host Alt-Names e.g. openssl x509 -in mycertfile.crt -text -noout \ -certopt no_subject,no_header,no_version,no_serial,no_signame,no_validity,no_subject,no_issuer,no_pubkey,no_sigdump,no_aux \| awk '/X509v3 Subject Alternative

Re: stunning error - Request of length 1550939497 is not valid, it is larger than the maximum size of 104857600 bytes

Hi Todd take a look at: chunked encoding implemented by NIOConnector https://publib.boulder.ibm.com/wasce/V2.1.0/en/http-connector.html IBM WebSphere Application Server Community Edition ... publib.boulder.ibm.com

Re: reacting to a truststore change

From: Tuan Dang Sent: Wednesday, December 7, 2016 10:00 AM To: users@kafka.apache.org Subject: reacting to a truststore change Hello all, I'm working my way through Kafka 0.9 SSL/TLS authentication. If I make a change to the

Re: Suggestions

Vincenzo Nota Bene: you can *force* resolution of a good version (3.4.8) to be used by all artifacts downstream from your parent pom.xml..the mechanism is called https://maven.apache.org/guides/introduction/introduction-to-dependency-mechanism.html#Dependency_Management Buona Fortuna

Re: Writing a customized principal builder for authorization

this is a quick and dirty test you can use: org.apache.kafka.common.network.SSLSelectorTest: //Truststore needs to contain keystore/cert that contains the actual principal you will use File trustStoreFile = File.createTempFile("truststore", ".jks"); Map

Re: Messages intermittently get lost

error: "(" unexpected (expecting "fi") Looks like a bug in the ZK shell script? Best, Zac ________ From: Martin Gainty <mgai...@hotmail.com> Sent: Tuesday, November 29, 2016 11:18:21 AM To: users@kafka.apache.org Subject: Re: Messages intermitte

Re: Writing a customized principal builder for authorization using ACLs

i would suggest understanding SunJSSE security provider(s) implemented by Oracle https://docs.oracle.com/javase/8/docs/technotes/guides/security/jsse/JSSERefGuide.html#SunJSSE i would also suggest understanding complimentary security providers from BouncyCastle

Re: Messages intermittently get lost

th ZooKeeper? ____ From: Martin Gainty <mgai...@hotmail.com> Sent: Friday, November 25, 2016 1:46:28 PM To: users@kafka.apache.org Subject: Re: Messages intermittently get lost From: Zac Harvey <zac.har...@welltok.com> S

Re: Messages intermittently get lost

Hi Zach there is a rumour that today thursday is a holiday? in server.properties how are you configuring your server? specifically what are these attributes? num.network.threads= num.io.threads= socket.send.buffer.bytes= socket.receive.buffer.bytes= socket.request.max.bytes=

Re: Can Kafka/SSL be terminated at a load balancer?

From: Zac Harvey Sent: Monday, November 21, 2016 8:59 AM To: users@kafka.apache.org Subject: Re: Can Kafka/SSL be terminated at a load balancer? Thanks again Rajini, Using these configs, would clients connect to the load balancer

  1   2   >