Page Menu
Home
Software Heritage
Search
Configure Global Search
Log In
Files
F8395649
producer_spec.rb
No One
Temporary
Actions
Download File
Edit File
Delete File
View Transforms
Subscribe
Mute Notifications
Award Token
Flag For Later
Size
4 KB
Subscribers
None
producer_spec.rb
View Options
require
'spec_helper_acceptance'
describe
'kafka::producer'
,
if
:
(
fact
(
'operatingsystemmajrelease'
)
==
'6'
&&
fact
(
'osfamily'
)
==
'RedHat'
)
do
# systemd systems not supported by kafka::producer::service
it
'works with no errors'
do
pp
=
<<-
EOS
exec { 'create fifo':
command => '/usr/bin/mkfifo /tmp/kafka-producer',
user => 'kafka',
creates => '/tmp/kafka-producer',
} ->
class { 'kafka::producer':
service_config => {
'broker-list' => 'localhost:9092',
topic => 'demo',
},
input => '3<>/tmp/kafka-producer 0>&3',
}
EOS
apply_manifest
(
pp
,
catch_failures
:
true
)
apply_manifest
(
pp
,
catch_changes
:
true
)
end
describe
'kafka::producer::install'
do
context
'with default parameters'
do
it
'works with no errors'
do
pp
=
<<-
EOS
exec { 'create fifo':
command => '/usr/bin/mkfifo /tmp/kafka-producer',
user => 'kafka',
creates => '/tmp/kafka-producer',
} ->
class { 'kafka::producer':
service_config => {
'broker-list' => 'localhost:9092',
topic => 'demo',
},
input => '3<>/tmp/kafka-producer 0>&3',
}
EOS
apply_manifest
(
pp
,
catch_failures
:
true
)
apply_manifest
(
pp
,
catch_changes
:
true
)
end
describe
group
(
'kafka'
)
do
it
{
is_expected
.
to
exist
}
end
describe
user
(
'kafka'
)
do
it
{
is_expected
.
to
exist
}
it
{
is_expected
.
to
belong_to_group
'kafka'
}
it
{
is_expected
.
to
have_login_shell
'/bin/bash'
}
end
describe
file
(
'/var/tmp/kafka'
)
do
it
{
is_expected
.
to
be_directory
}
it
{
is_expected
.
to
be_owned_by
'kafka'
}
it
{
is_expected
.
to
be_grouped_into
'kafka'
}
end
describe
file
(
'/opt/kafka-2.12-2.4.1'
)
do
it
{
is_expected
.
to
be_directory
}
it
{
is_expected
.
to
be_owned_by
'kafka'
}
it
{
is_expected
.
to
be_grouped_into
'kafka'
}
end
describe
file
(
'/opt/kafka'
)
do
it
{
is_expected
.
to
be_linked_to
(
'/opt/kafka-2.12-2.4.1'
)
}
end
describe
file
(
'/opt/kafka/config'
)
do
it
{
is_expected
.
to
be_directory
}
it
{
is_expected
.
to
be_owned_by
'kafka'
}
it
{
is_expected
.
to
be_grouped_into
'kafka'
}
end
describe
file
(
'/var/log/kafka'
)
do
it
{
is_expected
.
to
be_directory
}
it
{
is_expected
.
to
be_owned_by
'kafka'
}
it
{
is_expected
.
to
be_grouped_into
'kafka'
}
end
end
end
describe
'kafka::producer::config'
do
context
'with default parameters'
do
it
'works with no errors'
do
pp
=
<<-
EOS
exec { 'create fifo':
command => '/usr/bin/mkfifo /tmp/kafka-producer',
user => 'kafka',
creates => '/tmp/kafka-producer',
} ->
class { 'kafka::producer':
service_config => {
'broker-list' => 'localhost:9092',
topic => 'demo',
},
input => '3<>/tmp/kafka-producer 0>&3',
}
EOS
apply_manifest
(
pp
,
catch_failures
:
true
)
apply_manifest
(
pp
,
catch_changes
:
true
)
end
describe
file
(
'/opt/kafka/config/producer.properties'
)
do
it
{
is_expected
.
to
be_file
}
it
{
is_expected
.
to
be_owned_by
'kafka'
}
it
{
is_expected
.
to
be_grouped_into
'kafka'
}
end
end
end
describe
'kafka::producer::service'
do
context
'with default parameters'
do
it
'works with no errors'
do
pp
=
<<-
EOS
class { 'kafka::producer':
service_config => {
'broker-list' => 'localhost:9092',
topic => 'demo',
},
input => '3<>/tmp/kafka-producer 0>&3',
}
EOS
apply_manifest
(
pp
,
catch_failures
:
true
)
apply_manifest
(
pp
,
catch_changes
:
true
)
end
describe
file
(
'/etc/init.d/kafka-producer'
)
do
it
{
is_expected
.
to
be_file
}
it
{
is_expected
.
to
be_owned_by
'root'
}
it
{
is_expected
.
to
be_grouped_into
'root'
}
it
{
is_expected
.
to
contain
'export KAFKA_JMX_OPTS="-Dcom.sun.management.jmxremote -Dcom.sun.management.jmxremote.authenticate=false -Dcom.sun.management.jmxremote.ssl=false -Dcom.sun.management.jmxremote.port=9992"'
}
it
{
is_expected
.
to
contain
'export KAFKA_LOG4J_OPTS="-Dlog4j.configuration=file:/opt/kafka/config/log4j.properties"'
}
end
describe
service
(
'kafka-producer'
)
do
it
{
is_expected
.
to
be_running
}
it
{
is_expected
.
to
be_enabled
}
end
end
end
end
File Metadata
Details
Attached
Mime Type
text/x-ruby
Expires
Jun 4 2025, 7:42 PM (11 w, 4 d ago)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
3305234
Attached To
R143 puppet-puppet-kafka
Event Timeline
Log In to Comment